You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by le...@apache.org on 2019/12/10 11:23:48 UTC
[incubator-hudi] branch master updated (70a1040 -> d447e2d)
This is an automated email from the ASF dual-hosted git repository.
leesf pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-hudi.git.
from 70a1040 [MINOR] Beautify the cli banner (#1089)
add d447e2d [checkstyle] Unify LOG form (#1092)
No new revisions were added by this update.
Summary of changes:
.../hudi/cli/commands/CompactionCommand.java | 4 +-
.../cli/commands/HDFSParquetImportCommand.java | 2 +-
.../org/apache/hudi/cli/commands/SparkMain.java | 2 +-
.../apache/hudi/cli/utils/InputStreamConsumer.java | 2 +-
.../java/org/apache/hudi/cli/utils/SparkUtil.java | 2 +-
.../org/apache/hudi/CompactionAdminClient.java | 18 +++----
.../java/org/apache/hudi/HoodieCleanClient.java | 16 +++---
.../java/org/apache/hudi/HoodieWriteClient.java | 62 +++++++++++-----------
.../client/embedded/EmbeddedTimelineService.java | 12 ++---
.../bloom/BucketizedBloomCheckPartitioner.java | 10 ++--
.../apache/hudi/index/bloom/HoodieBloomIndex.java | 12 ++---
.../hbase/DefaultHBaseQPSResourceAllocator.java | 4 +-
.../org/apache/hudi/index/hbase/HBaseIndex.java | 44 +++++++--------
.../org/apache/hudi/io/HoodieAppendHandle.java | 14 ++---
.../java/org/apache/hudi/io/HoodieCleanHelper.java | 10 ++--
.../org/apache/hudi/io/HoodieCommitArchiveLog.java | 18 +++----
.../org/apache/hudi/io/HoodieCreateHandle.java | 10 ++--
.../org/apache/hudi/io/HoodieKeyLookupHandle.java | 20 +++----
.../java/org/apache/hudi/io/HoodieMergeHandle.java | 22 ++++----
.../java/org/apache/hudi/io/HoodieWriteHandle.java | 6 +--
.../io/compact/HoodieRealtimeTableCompactor.java | 22 ++++----
.../org/apache/hudi/metrics/HoodieMetrics.java | 10 ++--
.../apache/hudi/metrics/JmxMetricsReporter.java | 4 +-
.../main/java/org/apache/hudi/metrics/Metrics.java | 4 +-
.../hudi/metrics/MetricsGraphiteReporter.java | 6 +--
.../hudi/metrics/MetricsReporterFactory.java | 4 +-
.../apache/hudi/table/HoodieCopyOnWriteTable.java | 48 ++++++++---------
.../apache/hudi/table/HoodieMergeOnReadTable.java | 22 ++++----
.../java/org/apache/hudi/table/HoodieTable.java | 10 ++--
.../org/apache/hudi/table/RollbackExecutor.java | 10 ++--
hudi-client/src/test/java/HoodieClientExample.java | 8 +--
.../src/test/java/org/apache/hudi/TestCleaner.java | 4 +-
.../org/apache/hudi/TestCompactionAdminClient.java | 6 ++-
.../java/org/apache/hudi/TestHoodieClientBase.java | 2 +-
.../hudi/TestHoodieClientOnCopyOnWriteStorage.java | 6 ++-
.../src/test/java/org/apache/hudi/TestMultiFS.java | 10 ++--
.../apache/hudi/common/HoodieClientTestUtils.java | 2 +-
.../apache/hudi/table/TestCopyOnWriteTable.java | 4 +-
.../hudi/common/model/HoodieCommitMetadata.java | 4 +-
.../hudi/common/model/HoodiePartitionMetadata.java | 6 +--
.../common/model/HoodieRollingStatMetadata.java | 4 +-
.../hudi/common/table/HoodieTableConfig.java | 2 +-
.../hudi/common/table/HoodieTableMetaClient.java | 2 +-
.../table/timeline/HoodieActiveTimeline.java | 2 +-
.../table/timeline/HoodieArchivedTimeline.java | 2 +-
.../table/timeline/HoodieDefaultTimeline.java | 2 +-
.../table/view/AbstractTableFileSystemView.java | 16 +++---
.../common/table/view/FileSystemViewManager.java | 20 +++----
.../table/view/HoodieTableFileSystemView.java | 4 +-
.../IncrementalTimelineSyncFileSystemView.java | 42 +++++++--------
.../table/view/PriorityBasedFileSystemView.java | 18 +++----
.../view/RemoteHoodieTableFileSystemView.java | 4 +-
.../table/view/RocksDbBasedFileSystemView.java | 24 ++++-----
.../view/SpillableMapBasedFileSystemView.java | 6 +--
.../common/util/DFSPropertiesConfiguration.java | 4 +-
.../hudi/common/util/FailSafeConsistencyGuard.java | 2 +-
.../common/util/HoodieRecordSizeEstimator.java | 4 +-
.../org/apache/hudi/common/util/RocksDBDAO.java | 2 +-
.../hudi/common/util/TimelineDiffHelper.java | 6 +--
.../common/util/queue/BoundedInMemoryExecutor.java | 10 ++--
.../common/util/queue/BoundedInMemoryQueue.java | 4 +-
.../table/view/TestHoodieTableFileSystemView.java | 2 +-
.../table/view/TestIncrementalFSViewSync.java | 2 +-
.../hudi/hadoop/HoodieParquetInputFormat.java | 2 +-
.../hudi/hadoop/HoodieROTablePathFilter.java | 2 +-
.../hudi/hadoop/RecordReaderValueIterator.java | 2 +-
.../realtime/HoodieParquetRealtimeInputFormat.java | 2 +-
.../realtime/HoodieRealtimeRecordReader.java | 2 +-
.../java/org/apache/hudi/hive/HiveSyncTool.java | 2 +-
.../org/apache/hudi/hive/HoodieHiveClient.java | 2 +-
.../org/apache/hudi/hive/util/HiveTestService.java | 2 +-
hudi-spark/src/test/java/HoodieJavaApp.java | 12 ++---
.../src/test/java/HoodieJavaStreamingApp.java | 18 +++----
.../hudi/timeline/service/TimelineService.java | 8 +--
.../view/TestRemoteHoodieTableFileSystemView.java | 4 +-
.../apache/hudi/utilities/HDFSParquetImporter.java | 12 ++---
.../hudi/utilities/HiveIncrementalPuller.java | 40 +++++++-------
.../org/apache/hudi/utilities/HoodieCleaner.java | 4 +-
.../org/apache/hudi/utilities/HoodieCompactor.java | 4 +-
.../hudi/utilities/HoodieSnapshotCopier.java | 22 ++++----
.../org/apache/hudi/utilities/UtilHelpers.java | 10 ++--
.../adhoc/UpgradePayloadFromUberToApache.java | 14 ++---
.../AbstractDeltaStreamerService.java | 14 ++---
.../hudi/utilities/deltastreamer/Compactor.java | 6 +--
.../hudi/utilities/deltastreamer/DeltaSync.java | 34 ++++++------
.../deltastreamer/HoodieDeltaStreamer.java | 36 ++++++-------
.../deltastreamer/SchedulerConfGenerator.java | 6 +--
.../hudi/utilities/perf/TimelineServerPerf.java | 6 +--
.../hudi/utilities/sources/AvroKafkaSource.java | 4 +-
.../hudi/utilities/sources/HiveIncrPullSource.java | 6 +--
.../hudi/utilities/sources/HoodieIncrSource.java | 7 ++-
.../hudi/utilities/sources/JsonKafkaSource.java | 4 +-
.../org/apache/hudi/utilities/sources/Source.java | 2 +-
.../utilities/sources/helpers/KafkaOffsetGen.java | 2 +-
.../utilities/transform/FlatteningTransformer.java | 4 +-
.../transform/SqlQueryBasedTransformer.java | 6 +--
.../hudi/utilities/TestHoodieDeltaStreamer.java | 14 ++---
.../utilities/sources/AbstractBaseTestSource.java | 14 +++--
.../sources/DistributedTestDataSource.java | 8 ++-
.../hudi/utilities/sources/TestDataSource.java | 4 +-
100 files changed, 514 insertions(+), 493 deletions(-)