FlinkSourceBuilder |
FlinkSourceBuilder.withContinuousMode(boolean isContinuous) |
FlinkSourceBuilder |
FlinkSourceBuilder.withEnv(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env) |
FlinkSourceBuilder |
FlinkSourceBuilder.withLimit(Long limit) |
FlinkSourceBuilder |
FlinkSourceBuilder.withLogSourceProvider(LogSourceProvider logSourceProvider) |
FlinkSourceBuilder |
FlinkSourceBuilder.withParallelism(Integer parallelism) |
FlinkSourceBuilder |
FlinkSourceBuilder.withPredicate(Predicate predicate) |
FlinkSourceBuilder |
FlinkSourceBuilder.withProjection(int[][] projectedFields) |
FlinkSourceBuilder |
FlinkSourceBuilder.withWatermarkStrategy(org.apache.flink.api.common.eventtime.WatermarkStrategy<org.apache.flink.table.data.RowData> watermarkStrategy) |