postgresql spring-boot dataset apache-flink batch-processing

Is it possible to read data directly from a database table for batch processing in Apache Flink than reading from a csv file?

I need my Flink batch job to read data from my Spring Boot project's postgres database. The option I saw in Flink is only for reading from csv files. In that case I need to create a csv file from my table. Is there any solution out there?

Solution

If You want to read the data from Postgres (which I assume this question is about) You can use Flink JDBC connector, which will allow reading from various databases including the Postgres. You can find more info here.

ruby raised another command is already in progress
Find modal values in each row, with custom tie breaking in PostreSQL
Find procedure name in all other procedures
How to use posix regexp operator for substring match
How to get results from a Postgresql function using EF Core?
Sql Alchemy Insert Statement failing to insert, but no error
SELECT rows with the max count per column value after GROUP BY
Pick random values from different table-columns (postgresql)
django.db.utils.ProgrammingError: relation "bot_trade" does not exist
Supabase python client returns an empty list when making a query
How to calculate DATE Difference in PostgreSQL?
Repeat rows specified number of times in PostgreSQL
How to visualize database tables in postgresql using pgAdmin?
panic: sql: expected 1 destination arguments in Scan, not <number> golang, pq, sql
Why is Postgres not using my index on a simple ORDER BY LIMIT 1?
Npgsql: How to setup enum mapping in Npgsql v8?
How to reference another docker service from Dockerfile
How to differentiate a Cypher clause from an SQL clause in C?
using sql joins vs using separated methods in java
Prisma Supabase: Invalid format for user or db_name after initial migration
Laravel Model casts not working properly
Export specific rows from a PostgreSQL table as INSERT SQL script
Retaining and inserting state into a postgres aggregation function
Spring JPA with docker compose: Unable to determine Dialect without JDBC metadata (please set 'jakarta.persistence.jdbc.url' or 'hibernate.dialect'
PostgreSQL - ERROR: column does not exist SQL state: 42703
Function to return dynamic set of columns for given table
How to force evaluation of subquery before joining / pushing down to foreign server
How to install postgresql-client to Amazon EC2 Linux machine?
Unterminated dollar-quoted string reported by goose when creating PostgreSQL function
How to compute the sum of multiple columns in PostgreSQL