|
199 | 199 | WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
200 | 200 | See the License for the specific language governing permissions and |
201 | 201 | limitations under the License. |
| 202 | + |
| 203 | + |
| 204 | +------------------------------------------------------------------------------------ |
| 205 | +This product bundles various third-party components under the same license. |
| 206 | +This section summarizes those components. |
| 207 | + |
| 208 | + |
| 209 | +Apache License 2.0 |
| 210 | +-------------------------------------- |
| 211 | + |
| 212 | +Apache Arrow-java |
| 213 | +./fluss-common/src/main/java/com/alibaba/fluss/compression/ArrowCompressionFactory.java |
| 214 | +./fluss-common/src/main/java/com/alibaba/fluss/compression/Lz4ArrowCompressionCodec.java |
| 215 | +./fluss-common/src/main/java/com/alibaba/fluss/compression/ZstdArrowCompressionCodec.java |
| 216 | + |
| 217 | +Apache Flink |
| 218 | +./fluss-client/src/main/java/com/alibaba/fluss/client/token/DefaultSecurityTokenManager.java |
| 219 | +./fluss-common/src/main/java/com/alibaba/fluss/classloading/ComponentClassLoader.java |
| 220 | +./fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOption.java |
| 221 | +./fluss-common/src/main/java/com/alibaba/fluss/config/Configuration.java |
| 222 | +./fluss-common/src/main/java/com/alibaba/fluss/config/ConfigurationUtils.java |
| 223 | +./fluss-common/src/main/java/com/alibaba/fluss/config/GlobalConfiguration.java |
| 224 | +./fluss-common/src/main/java/com/alibaba/fluss/config/MemorySize.java |
| 225 | +./fluss-common/src/main/java/com/alibaba/fluss/fs/FSDataOutputStream.java |
| 226 | +./fluss-common/src/main/java/com/alibaba/fluss/fs/FileSystem.java |
| 227 | +./fluss-common/src/main/java/com/alibaba/fluss/fs/FileSystemSafetyNet.java |
| 228 | +./fluss-common/src/main/java/com/alibaba/fluss/fs/FsPath.java |
| 229 | +./fluss-common/src/main/java/com/alibaba/fluss/fs/SafetyNetCloseableRegistry.java |
| 230 | +./fluss-common/src/main/java/com/alibaba/fluss/fs/SafetyNetWrapperFileSystem.java |
| 231 | +./fluss-common/src/main/java/com/alibaba/fluss/fs/local/LocalFileSystem.java |
| 232 | +./fluss-common/src/main/java/com/alibaba/fluss/memory/AbstractPagedOutputView.java |
| 233 | +./fluss-common/src/main/java/com/alibaba/fluss/memory/MemorySegment.java |
| 234 | +./fluss-common/src/main/java/com/alibaba/fluss/memory/MemoryUtils.java |
| 235 | +./fluss-common/src/main/java/com/alibaba/fluss/metrics/MeterView.java |
| 236 | +./fluss-common/src/main/java/com/alibaba/fluss/metrics/groups/AbstractMetricGroup.java |
| 237 | +./fluss-common/src/main/java/com/alibaba/fluss/metrics/groups/MetricGroup.java |
| 238 | +./fluss-common/src/main/java/com/alibaba/fluss/metrics/registry/MetricRegistryImpl.java |
| 239 | +./fluss-common/src/main/java/com/alibaba/fluss/plugin/DefaultPluginManager.java |
| 240 | +./fluss-common/src/main/java/com/alibaba/fluss/plugin/DirectoryBasedPluginFinder.java |
| 241 | +./fluss-common/src/main/java/com/alibaba/fluss/plugin/PluginLoader.java |
| 242 | +./fluss-common/src/main/java/com/alibaba/fluss/row/BinarySegmentUtils.java |
| 243 | +./fluss-common/src/main/java/com/alibaba/fluss/row/BinaryString.java |
| 244 | +./fluss-common/src/main/java/com/alibaba/fluss/row/Decimal.java |
| 245 | +./fluss-common/src/main/java/com/alibaba/fluss/types/DataType.java |
| 246 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/AbstractAutoCloseableRegistry.java |
| 247 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/DateTimeUtils.java |
| 248 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/DecimalUtils.java |
| 249 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/ExceptionUtils.java |
| 250 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/ExecutorUtils.java |
| 251 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/FatalExitExceptionHandler.java |
| 252 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/FileUtils.java |
| 253 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/IOUtils.java |
| 254 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/InstantiationUtils.java |
| 255 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/MurmurHashUtils.java |
| 256 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/NetUtils.java |
| 257 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/OperatingSystem.java |
| 258 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/SerializedValue.java |
| 259 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/TimeUtils.java |
| 260 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/UnsafeUtils.java |
| 261 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/concurrent/ExecutorThreadFactory.java |
| 262 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/concurrent/FutureUtils.java |
| 263 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/types/Either.java |
| 264 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/types/Tuple.java |
| 265 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/types/Tuple2.java |
| 266 | +./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/HadoopDataInputStream.java |
| 267 | +./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/HadoopDataOutputStream.java |
| 268 | +./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/HadoopFileSystem.java |
| 269 | +./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/HadoopFsPlugin.java |
| 270 | +./fluss-filesystems/fluss-fs-hadoop/src/main/java/com/alibaba/fluss/fs/hdfs/utils/HadoopUtils.java |
| 271 | +./fluss-filesystems/fluss-fs-oss/src/main/java/com/alibaba/fluss/fs/oss/OSSFileSystem.java |
| 272 | +./fluss-filesystems/fluss-fs-oss/src/main/java/com/alibaba/fluss/fs/oss/OSSFileSystemPlugin.java |
| 273 | +./fluss-filesystems/fluss-fs-s3/src/main/java/com/alibaba/fluss/fs/s3/token/S3DelegationTokenReceiver.java |
| 274 | +./fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/CatalogPropertiesUtils.java |
| 275 | +./fluss-metrics/fluss-metrics-jmx/src/main/java/com/alibaba/fluss/metrics/jmx/JMXService.java |
| 276 | +./fluss-metrics/fluss-metrics-prometheus/src/main/java/com/alibaba/fluss/metrics/prometheus/PrometheusReporter.java |
| 277 | +./fluss-metrics/fluss-metrics-prometheus/src/main/java/com/alibaba/fluss/metrics/prometheus/PrometheusReporterPlugin.java |
| 278 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/rocksdb/RocksDBKvBuilder.java |
| 279 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/rocksdb/RocksDBResourceContainer.java |
| 280 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/rocksdb/RocksDBWriteBatchWrapper.java |
| 281 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/AsyncSnapshotCallable.java |
| 282 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshot.java |
| 283 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshotHandle.java |
| 284 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/CompletedSnapshotStore.java |
| 285 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/PeriodicSnapshotManager.java |
| 286 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/RocksIncrementalSnapshot.java |
| 287 | +./fluss-server/src/main/java/com/alibaba/fluss/server/kv/snapshot/SharedKvFileRegistry.java |
| 288 | +./fluss-server/src/main/java/com/alibaba/fluss/server/metrics/ServerMetricUtils.java |
| 289 | +./fluss-server/src/main/java/com/alibaba/fluss/server/utils/ResourceGuard.java |
| 290 | +./fluss-server/src/main/java/com/alibaba/fluss/server/utils/ShutdownHookUtil.java |
| 291 | +./fluss-test-utils/src/main/java/com/alibaba/fluss/testutils/common/TestLoggerExtension.java |
| 292 | + |
| 293 | +Apache Kafka |
| 294 | +./fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetchBuffer.java |
| 295 | +./fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetchCollector.java |
| 296 | +./fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetcher.java |
| 297 | +./fluss-client/src/main/java/com/alibaba/fluss/client/write/IdempotenceManager.java |
| 298 | +./fluss-client/src/main/java/com/alibaba/fluss/client/write/RecordAccumulator.java |
| 299 | +./fluss-client/src/main/java/com/alibaba/fluss/client/write/Sender.java |
| 300 | +./fluss-common/src/main/java/com/alibaba/fluss/compression/FlussLZ4BlockInputStream.java |
| 301 | +./fluss-common/src/main/java/com/alibaba/fluss/compression/FlussLZ4BlockOutputStream.java |
| 302 | +./fluss-common/src/main/java/com/alibaba/fluss/record/DefaultLogRecordBatch.java |
| 303 | +./fluss-common/src/main/java/com/alibaba/fluss/record/FileLogInputStream.java |
| 304 | +./fluss-common/src/main/java/com/alibaba/fluss/record/FileLogRecords.java |
| 305 | +./fluss-common/src/main/java/com/alibaba/fluss/record/IndexedLogRecord.java |
| 306 | +./fluss-common/src/main/java/com/alibaba/fluss/record/MemoryLogRecords.java |
| 307 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/concurrent/FlussScheduler.java |
| 308 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/crc/Checksums.java |
| 309 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/crc/Crc32C.java |
| 310 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/crc/Java.java |
| 311 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/crc/PureJavaCrc32C.java |
| 312 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/log/ByteBufferUnmapper.java |
| 313 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/log/FairBucketStatusMap.java |
| 314 | +./fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine/ReplicaStateMachine.java |
| 315 | +./fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine/TableBucketStateMachine.java |
| 316 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/AbstractIndex.java |
| 317 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/LazyIndex.java |
| 318 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/LocalLog.java |
| 319 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogLoader.java |
| 320 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogManager.java |
| 321 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetMetadata.java |
| 322 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogOffsetSnapshot.java |
| 323 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogSegment.java |
| 324 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogSegments.java |
| 325 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/LogTablet.java |
| 326 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/OffsetIndex.java |
| 327 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/TimeIndex.java |
| 328 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java |
| 329 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/checkpoint/CheckpointFile.java |
| 330 | +./fluss-server/src/main/java/com/alibaba/fluss/server/log/checkpoint/OffsetCheckpointFile.java |
| 331 | +./fluss-server/src/main/java/com/alibaba/fluss/server/replica/AdjustIsrManager.java |
| 332 | +./fluss-server/src/main/java/com/alibaba/fluss/server/replica/FollowerReplica.java |
| 333 | +./fluss-server/src/main/java/com/alibaba/fluss/server/replica/IsrState.java |
| 334 | +./fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedFetchLog.java |
| 335 | +./fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedOperation.java |
| 336 | +./fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedOperationManager.java |
| 337 | +./fluss-server/src/main/java/com/alibaba/fluss/server/replica/delay/DelayedWrite.java |
| 338 | +./fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherManager.java |
| 339 | +./fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherThread.java |
| 340 | +./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/DefaultTimer.java |
| 341 | +./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/Timer.java |
| 342 | +./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/TimerTask.java |
| 343 | +./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/TimerTaskEntry.java |
| 344 | +./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/TimerTaskList.java |
| 345 | +./fluss-server/src/main/java/com/alibaba/fluss/server/utils/timer/TimingWheel.java |
| 346 | + |
| 347 | +Apache Paimon |
| 348 | +./fluss-common/src/main/java/com/alibaba/fluss/row/encode/paimon/PaimonBinaryRowWriter.java |
| 349 | +./fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/lakehouse/paimon/reader/PaimonSnapshotScanner.java |
| 350 | +./fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/PaimonMultiTableSink.java |
| 351 | +./fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/committable/PaimonMultiTableCommittableSerializer.java |
| 352 | +./fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/committer/PaimonStoreMultiCommitter.java |
| 353 | +./fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/operator/PaimonMultiWriterOperator.java |
| 354 | + |
| 355 | +Apache Spark |
| 356 | +./fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/NettyLogger.java |
| 357 | + |
| 358 | +LightProto |
| 359 | +./fluss-common/src/main/java/com/alibaba/fluss/utils/ProtoCodecUtils.java |
| 360 | +./fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtoGen.java |
| 361 | +./fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufMessage.java |
| 362 | +./fluss-protogen/fluss-protogen-generator/src/main/java/com/alibaba/fluss/protogen/generator/generator/ProtobufNumberField.java |
| 363 | +./fluss-protogen/fluss-protogen-maven-plugin/src/main/java/com/alibaba/fluss/protogen/maven/plugin/ProtoGenMojo.java |
0 commit comments