This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 97eb584 [minor] Rework Javadoc in Sink interface
add eb96cb2 [hotfix][table-common] Improve SupportsPartitioning
documentation
add 14a4f1c [hotfix][table-common] Return serializable
SerializationSchema instances in TestSchemaFactory
add dab3858 [hotfix][table-common] Add
LogicalTypeChecks.hasWellDefinedString
add fc1fc14 [hotfix][table] Promote JoinedRowData to flink-table-common
add 275ba78 [hotfix][table] Implement equals and hashCode in JoinedRowData
add e3cd3c2 [FLINK-18858][connector-kinesis] Use forward-compatible Guava
API
add 322a357 [FLINK-18858][connector-kinesis] Add Kinesis sources and sinks
add 8efa521 [hotfix][table] Move JoinedRowData to utils subpackage
No new revisions were added by this update.
Summary of changes:
docs/dev/connectors/kinesis.md | 12 +-
docs/dev/table/connectors/formats/index.md | 3 +
docs/dev/table/connectors/formats/index.zh.md | 3 +
docs/dev/table/connectors/kinesis.md | 753 +++++++++++++++++++++
docs/dev/table/connectors/kinesis.zh.md | 753 +++++++++++++++++++++
docs/redirects/kinesis.md | 2 +-
flink-connectors/flink-connector-kinesis/pom.xml | 134 ++--
.../kinesis/FixedKinesisPartitioner.java | 77 +++
.../connectors/kinesis/FlinkKinesisProducer.java | 3 +-
.../connectors/kinesis/KinesisPartitioner.java | 4 +
.../kinesis/RandomKinesisPartitioner.java | 47 ++
.../kinesis/table/KinesisDynamicSink.java | 163 +++++
.../kinesis/table/KinesisDynamicSource.java | 223 ++++++
.../kinesis/table/KinesisDynamicTableFactory.java | 167 +++++
.../connectors/kinesis/table/KinesisOptions.java | 283 ++++++++
.../table/RowDataFieldsKinesisPartitioner.java | 271 ++++++++
.../table/RowDataKinesisDeserializationSchema.java | 140 ++++
.../org.apache.flink.table.factories.Factory | 16 +
.../table/KinesisDynamicTableFactoryTest.java | 382 +++++++++++
.../table/RowDataFieldsKinesisPartitionerTest.java | 322 +++++++++
...stractArrowPythonAggregateFunctionOperator.java | 2 +-
...PythonGroupWindowAggregateFunctionOperator.java | 2 +-
...PythonGroupWindowAggregateFunctionOperator.java | 2 +-
...bstractRowDataPythonScalarFunctionOperator.java | 2 +-
.../table/RowDataPythonTableFunctionOperator.java | 2 +-
.../sink/abilities/SupportsPartitioning.java | 14 +-
.../flink/table/data/utils}/JoinedRowData.java | 29 +-
.../types/logical/utils/LogicalTypeChecks.java | 28 +
.../flink/table/factories/TableOptionsBuilder.java | 64 ++
.../flink/table/factories/TestFormatFactory.java | 64 +-
.../flink/table/planner/codegen/CodeGenUtils.scala | 9 +-
.../planner/codegen/CorrelateCodeGenerator.scala | 10 +-
.../table/planner/codegen/GenerateUtils.scala | 1 +
.../planner/codegen/LongHashJoinGenerator.scala | 3 +-
.../planner/codegen/LookupJoinCodeGenerator.scala | 10 +-
.../codegen/NestedLoopJoinCodeGenerator.scala | 10 +-
.../codegen/agg/batch/HashAggCodeGenHelper.scala | 3 +-
.../codegen/agg/batch/HashAggCodeGenerator.scala | 7 +-
.../codegen/agg/batch/SortAggCodeGenerator.scala | 6 +-
.../codegen/agg/batch/WindowCodeGenerator.scala | 3 +-
.../planner/plan/utils/IntervalJoinUtil.scala | 20 +-
.../operators/aggregate/GroupAggFunction.java | 2 +-
.../aggregate/MiniBatchGlobalGroupAggFunction.java | 2 +-
.../aggregate/MiniBatchGroupAggFunction.java | 2 +-
.../MiniBatchIncrementalGroupAggFunction.java | 2 +-
.../aggregate/MiniBatchLocalGroupAggFunction.java | 2 +-
.../runtime/operators/join/HashJoinOperator.java | 2 +-
.../operators/join/OuterJoinPaddingUtil.java | 2 +-
.../operators/join/SortMergeJoinOperator.java | 2 +-
.../join/lookup/AsyncLookupJoinRunner.java | 2 +-
.../operators/join/lookup/LookupJoinRunner.java | 2 +-
.../join/stream/StreamingJoinOperator.java | 2 +-
.../temporal/TemporalProcessTimeJoinOperator.java | 2 +-
.../join/temporal/TemporalRowTimeJoinOperator.java | 2 +-
.../AbstractRowTimeUnboundedPrecedingOver.java | 2 +-
.../over/BufferDataOverWindowOperator.java | 2 +-
.../over/NonBufferOverWindowOperator.java | 2 +-
.../ProcTimeRangeBoundedPrecedingFunction.java | 2 +-
.../over/ProcTimeRowsBoundedPrecedingFunction.java | 2 +-
.../over/ProcTimeUnboundedPrecedingFunction.java | 2 +-
.../over/RowTimeRangeBoundedPrecedingFunction.java | 2 +-
.../over/RowTimeRowsBoundedPrecedingFunction.java | 2 +-
.../operators/rank/AbstractTopNFunction.java | 2 +-
.../table/runtime/operators/sort/RankOperator.java | 2 +-
.../operators/window/AggregateWindowOperator.java | 2 +-
.../org/apache/flink/table/data/RowDataTest.java | 1 +
.../aggregate/SumHashAggTestOperator.java | 2 +-
.../operators/join/Int2HashJoinOperatorTest.java | 2 +-
.../operators/join/LookupJoinHarnessTest.java | 2 +-
.../join/RandomSortMergeInnerJoinTest.java | 2 +-
.../join/String2HashJoinOperatorTest.java | 2 +-
.../join/String2SortMergeJoinOperatorTest.java | 2 +-
.../interval/TimeIntervalStreamJoinTestBase.java | 2 +-
.../operators/window/WindowOperatorTest.java | 2 +-
74 files changed, 3940 insertions(+), 174 deletions(-)
create mode 100644 docs/dev/table/connectors/kinesis.md
create mode 100644 docs/dev/table/connectors/kinesis.zh.md
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FixedKinesisPartitioner.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/RandomKinesisPartitioner.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicSink.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicSource.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicTableFactory.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisOptions.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataFieldsKinesisPartitioner.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataKinesisDeserializationSchema.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
create mode 100644
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicTableFactoryTest.java
create mode 100644
flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/table/RowDataFieldsKinesisPartitionerTest.java
rename
flink-table/{flink-table-runtime-blink/src/main/java/org/apache/flink/table/data
=>
flink-table-common/src/main/java/org/apache/flink/table/data/utils}/JoinedRowData.java
(86%)
create mode 100644
flink-table/flink-table-common/src/test/java/org/apache/flink/table/factories/TableOptionsBuilder.java
