This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
from 8804a300c [INLONG-4155][Manager] Change constants and remove clone
method in WorkflowContext (#4160)
add 76b9c6420 [INLONG-4169][Sort] Add comments before classes (#4176)
No new revisions were added by this update.
Summary of changes:
.../inlong/sort/standalone/utils/FlumeConfigGenerator.java | 3 +++
.../sort-api/src/main/java/org/apache/inlong/sort/ZkTools.java | 6 ++++++
.../java/org/apache/inlong/sort/configuration/Constants.java | 3 +++
.../java/org/apache/inlong/sort/configuration/FallbackKey.java | 1 -
.../org/apache/inlong/sort/protocol/DataFlowStorageInfo.java | 4 ++++
.../sort/protocol/deserialization/AvroDeserializationInfo.java | 3 +++
.../sort/protocol/deserialization/CanalDeserializationInfo.java | 3 +++
.../sort/protocol/deserialization/CsvDeserializationInfo.java | 2 +-
.../protocol/deserialization/DebeziumDeserializationInfo.java | 3 +++
.../sort/protocol/deserialization/JsonDeserializationInfo.java | 3 +++
.../sort/protocol/deserialization/KvDeserializationInfo.java | 2 +-
.../java/org/apache/inlong/sort/protocol/node/ExtractNode.java | 3 +++
.../main/java/org/apache/inlong/sort/protocol/node/LoadNode.java | 3 +++
.../src/main/java/org/apache/inlong/sort/protocol/node/Node.java | 3 +++
.../inlong/sort/protocol/node/extract/MySqlExtractNode.java | 3 +++
.../java/org/apache/inlong/sort/protocol/node/format/Format.java | 4 ++++
.../org/apache/inlong/sort/protocol/node/load/HiveLoadNode.java | 3 +++
.../org/apache/inlong/sort/protocol/node/load/KafkaLoadNode.java | 3 +++
.../inlong/sort/protocol/node/transform/TransformNode.java | 3 +++
.../sort/protocol/serialization/AvroSerializationInfo.java | 3 +++
.../sort/protocol/serialization/CanalSerializationInfo.java | 3 +++
.../inlong/sort/protocol/serialization/SerializationInfo.java | 3 +++
.../inlong/sort/protocol/transformation/CompareOperator.java | 3 +++
.../inlong/sort/protocol/transformation/FieldMappingRule.java | 3 +++
.../inlong/sort/protocol/transformation/FieldRelationShip.java | 5 +++++
.../inlong/sort/protocol/transformation/FilterFunction.java | 3 +++
.../sort/protocol/transformation/GroupTimeWindowFunction.java | 4 ++++
.../inlong/sort/protocol/transformation/OrderDirection.java | 3 +++
.../inlong/sort/protocol/transformation/TimeWindowFunction.java | 3 +++
.../inlong/sort/protocol/transformation/WatermarkField.java | 3 +++
.../sort/protocol/transformation/function/HopEndFunction.java | 3 +++
.../sort/protocol/transformation/function/HopFunction.java | 8 ++++++++
.../sort/protocol/transformation/function/HopStartFunction.java | 3 +++
.../transformation/function/MultiValueFilterFunction.java | 4 ++++
.../protocol/transformation/function/SessionEndFunction.java | 3 +++
.../sort/protocol/transformation/function/SessionFunction.java | 8 ++++++++
.../protocol/transformation/function/SessionStartFunction.java | 3 +++
.../transformation/function/SingleValueFilterFunction.java | 4 ++++
.../sort/protocol/transformation/function/TumbleEndFunction.java | 3 +++
.../sort/protocol/transformation/function/TumbleFunction.java | 9 +++++++++
.../protocol/transformation/function/TumbleStartFunction.java | 4 ++++
.../java/org/apache/inlong/sort/util/DefaultValueStrategy.java | 4 ++++
.../sort/flink/clickhouse/ClickHouseConnectionProvider.java | 4 ++++
.../inlong/sort/flink/clickhouse/ClickHouseRowConverter.java | 3 +++
.../inlong/sort/flink/clickhouse/ClickHouseSinkFunction.java | 3 +++
.../inlong/sort/flink/clickhouse/ClickHouseStatementFactory.java | 3 +++
.../sort/flink/clickhouse/executor/ClickHouseAppendExecutor.java | 4 ++++
.../sort/flink/clickhouse/executor/ClickHouseExecutor.java | 3 +++
.../flink/clickhouse/executor/ClickHouseExecutorFactory.java | 3 +++
.../flink/clickhouse/output/AbstractClickHouseOutputFormat.java | 4 ++++
.../flink/clickhouse/output/ClickHouseBatchOutputFormat.java | 3 +++
.../flink/clickhouse/output/ClickHouseOutputFormatFactory.java | 3 +++
.../flink/clickhouse/output/ClickHouseShardOutputFormat.java | 4 ++++
.../sort/flink/clickhouse/partitioner/BalancePartitioner.java | 4 ++++
.../sort/flink/clickhouse/partitioner/ClickHousePartitioner.java | 3 +++
.../sort/flink/clickhouse/partitioner/HashPartitioner.java | 3 +++
.../sort/flink/clickhouse/partitioner/RandomPartitioner.java | 3 +++
.../org/apache/inlong/sort/flink/doris/DorisSinkFunction.java | 3 +++
.../apache/inlong/sort/flink/doris/load/DorisBeInfoResponse.java | 3 +++
.../apache/inlong/sort/flink/doris/load/DorisRowConverter.java | 3 +++
.../org/apache/inlong/sort/flink/doris/load/DorisStreamLoad.java | 3 +++
.../apache/inlong/sort/flink/doris/output/DorisOutputFormat.java | 3 +++
.../inlong/sort/flink/hive/HivePartitionBucketAssigner.java | 3 +++
.../org/apache/inlong/sort/flink/hive/formats/TextRowWriter.java | 1 +
.../inlong/sort/flink/hive/partition/JdbcHivePartitionTool.java | 3 +++
.../org/apache/inlong/sort/flink/kafka/KafkaSinkBuilder.java | 3 +++
.../inlong/sort/flink/pulsar/PulsarDeserializationSchema.java | 3 +++
.../main/java/org/apache/inlong/sort/flink/SerializedRecord.java | 3 +++
.../inlong/sort/flink/deserialization/DeserializationSchema.java | 3 +++
.../apache/inlong/sort/flink/deserialization/Deserializer.java | 3 +++
.../sort/flink/deserialization/MultiTenancyDeserializer.java | 4 ++++
.../java/org/apache/inlong/sort/flink/metrics/MetricData.java | 3 +++
.../org/apache/inlong/sort/flink/metrics/MetricsAggregator.java | 3 +++
.../flink/metrics/MetricsAssignerWithPeriodicWatermarks.java | 4 ++++
.../org/apache/inlong/sort/flink/metrics/MetricsLogSink.java | 3 +++
.../multitenant/clickhouse/ClickHouseMultiSinkFunction.java | 5 +++++
.../sort/flink/multitenant/doris/DorisMultiSinkFunction.java | 5 +++++
.../sort/flink/multitenant/hive/HiveMultiTenantCommitter.java | 5 +++++
.../sort/flink/multitenant/hive/HiveMultiTenantWriter.java | 5 +++++
.../flink/multitenant/pulsar/MultiTenancyPulsarConsumer.java | 5 +++++
.../flink/multitenant/pulsar/MultiTopicPulsarSourceFunction.java | 5 +++++
.../sort/flink/multitenant/tubemq/MultiTenancyTubeConsumer.java | 4 ++++
.../flink/multitenant/tubemq/MultiTopicTubeSourceFunction.java | 3 +++
.../inlong/sort/formats/inlongmsg/InLongMsgFormatFactory.java | 3 +++
.../apache/inlong/sort/singletenant/flink/SerializedRecord.java | 3 +++
.../singletenant/flink/clickhouse/ClickhouseRowSinkFunction.java | 3 +++
.../sort/singletenant/flink/connectors/hive/HiveValidator.java | 3 +++
.../hive/table/catalog/factories/HiveTableInlongFactory.java | 3 +++
.../flink/deserialization/CanalDeserializationSchemaBuilder.java | 3 +++
.../sort/singletenant/flink/pulsar/PulsarSourceBuilder.java | 3 +++
.../sort/singletenant/flink/transformation/Transformer.java | 4 ++++
91 files changed, 313 insertions(+), 3 deletions(-)
