This is an automated email from the ASF dual-hosted git repository.
ctubbsii pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/fluo.git.
from 91c2603 Fixes #918 Prevent comma splitting for config override (#919)
new 8d3cfd3 Use latest Fluo Parent POM (version 2)
new 42e84cd Update formatting for latest Eclipse formatter
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../iterators/GarbageCollectionIterator.java | 4 +-
.../accumulo/iterators/NotificationIterator.java | 12 +-
.../fluo/accumulo/iterators/PrewriteIterator.java | 4 +-
.../fluo/accumulo/iterators/SnapshotIterator.java | 4 +-
.../accumulo/iterators/SnapshotIteratorTest.java | 5 +-
.../apache/fluo/accumulo/iterators/TestData.java | 5 +-
.../fluo/api/client/AbstractTransactionBase.java | 4 +-
.../java/org/apache/fluo/api/client/FluoAdmin.java | 4 +-
.../org/apache/fluo/api/client/FluoFactory.java | 5 +-
.../org/apache/fluo/api/client/SnapshotBase.java | 3 +-
.../apache/fluo/api/config/FluoConfiguration.java | 36 +++---
.../main/java/org/apache/fluo/api/data/Bytes.java | 5 +-
.../java/org/apache/fluo/api/data/RowColumn.java | 4 +-
.../main/java/org/apache/fluo/api/data/Span.java | 10 +-
.../api/client/AbstractTransactionBaseTest.java | 8 +-
.../fluo/api/client/scanner/ScannerStreamTest.java | 20 ++--
.../fluo/api/config/FluoConfigurationTest.java | 17 ++-
.../org/apache/fluo/api/data/BytesBuilderTest.java | 5 +-
.../java/org/apache/fluo/api/data/ColumnTest.java | 4 +-
.../org/apache/fluo/api/data/RowColumnTest.java | 8 +-
.../java/org/apache/fluo/api/data/SpanTest.java | 73 ++++++------
.../apache/fluo/cluster/command/FluoCommand.java | 9 +-
.../org/apache/fluo/cluster/runner/AppRunner.java | 5 +-
.../fluo/cluster/runner/ClusterAppRunner.java | 12 +-
.../apache/fluo/cluster/runner/YarnAppRunner.java | 39 +++----
.../org/apache/fluo/cluster/util/FluoInstall.java | 3 +-
.../org/apache/fluo/cluster/yarn/FluoTwillApp.java | 23 ++--
.../java/org/apache/fluo/command/FluoInit.java | 4 +-
.../java/org/apache/fluo/command/FluoScan.java | 4 +-
.../fluo/core/async/AsyncConditionalWriter.java | 14 +--
.../org/apache/fluo/core/client/FluoAdminImpl.java | 37 +++---
.../apache/fluo/core/client/FluoClientImpl.java | 4 +-
.../fluo/core/client/LoaderExecutorAsyncImpl.java | 5 +-
.../org/apache/fluo/core/impl/Environment.java | 7 +-
.../fluo/core/impl/FluoConfigurationImpl.java | 12 +-
.../org/apache/fluo/core/impl/LockResolver.java | 17 ++-
.../fluo/core/impl/ParallelSnapshotScanner.java | 3 +-
.../apache/fluo/core/impl/SharedBatchWriter.java | 3 +-
.../org/apache/fluo/core/impl/SharedResources.java | 28 ++---
.../apache/fluo/core/impl/TimestampTracker.java | 13 +--
.../org/apache/fluo/core/impl/TransactionImpl.java | 42 ++++---
.../org/apache/fluo/core/impl/TransactorCache.java | 15 ++-
.../org/apache/fluo/core/impl/TransactorID.java | 5 +-
.../org/apache/fluo/core/impl/TransactorNode.java | 5 +-
.../java/org/apache/fluo/core/impl/TxInfo.java | 4 +-
.../org/apache/fluo/core/impl/TxInfoCache.java | 5 +-
.../java/org/apache/fluo/core/impl/TxStats.java | 4 +-
.../org/apache/fluo/core/impl/VisibilityCache.java | 3 +-
.../apache/fluo/core/log/TracingCellScanner.java | 12 +-
.../apache/fluo/core/log/TracingColumnScanner.java | 12 +-
.../apache/fluo/core/log/TracingTransaction.java | 27 ++---
.../org/apache/fluo/core/metrics/MetricNames.java | 8 +-
.../fluo/core/metrics/MetricsReporterImpl.java | 4 +-
.../org/apache/fluo/core/metrics/MetricsUtil.java | 5 +-
.../org/apache/fluo/core/metrics/ReporterUtil.java | 5 +-
.../metrics/starters/ConsoleReporterStarter.java | 5 +-
.../core/metrics/starters/CsvReporterStarter.java | 5 +-
.../metrics/starters/Slf4jReporterStarter.java | 5 +-
.../fluo/core/observer/v1/ObserverStoreV1.java | 8 +-
.../apache/fluo/core/observer/v1/ObserversV1.java | 6 +-
.../fluo/core/observer/v2/JsonObservers.java | 10 +-
.../fluo/core/observer/v2/ObserverRegistry.java | 16 +--
.../fluo/core/observer/v2/ObserverStoreV2.java | 4 +-
.../org/apache/fluo/core/oracle/OracleClient.java | 25 ++--
.../org/apache/fluo/core/oracle/OracleServer.java | 25 ++--
.../org/apache/fluo/core/thrift/OracleService.java | 128 ++++++++++-----------
.../java/org/apache/fluo/core/thrift/Stamps.java | 7 +-
.../org/apache/fluo/core/util/AccumuloUtil.java | 7 +-
.../java/org/apache/fluo/core/util/ColumnUtil.java | 6 +-
.../org/apache/fluo/core/util/CuratorUtil.java | 12 +-
.../org/apache/fluo/core/util/FluoExecutors.java | 37 +++---
.../apache/fluo/core/util/FluoThreadFactory.java | 1 -
.../java/org/apache/fluo/core/util/ScanUtil.java | 22 ++--
.../core/worker/NotificationFinderFactory.java | 5 +-
.../fluo/core/worker/NotificationProcessor.java | 9 +-
.../core/worker/finder/hash/PartitionManager.java | 27 ++---
.../finder/hash/PartitionNotificationFinder.java | 5 +-
.../core/worker/finder/hash/SerializedSplits.java | 5 +-
.../fluo/core/worker/finder/hash/TableRange.java | 4 +-
.../org/apache/fluo/core/util/ByteUtilTest.java | 7 +-
.../worker/finder/hash/PartitionManagerTest.java | 10 +-
.../worker/finder/hash/SerializedSplitsTest.java | 15 +--
.../core/worker/finder/hash/TableRangeTest.java | 5 +-
.../java/org/apache/fluo/integration/BankUtil.java | 3 +-
.../java/org/apache/fluo/integration/ITBase.java | 8 +-
.../apache/fluo/integration/TestTransaction.java | 8 +-
.../fluo/integration/client/FluoAdminImplIT.java | 3 +-
.../apache/fluo/integration/impl/CollisionIT.java | 9 +-
.../apache/fluo/integration/impl/FaultyConfig.java | 3 +-
.../org/apache/fluo/integration/impl/FluoIT.java | 5 +-
.../fluo/integration/impl/ObserverConfigIT.java | 19 ++-
.../apache/fluo/integration/impl/ScannerIT.java | 23 ++--
.../fluo/integration/impl/StochasticBankIT.java | 4 +-
.../integration/impl/StrongNotificationIT.java | 7 +-
.../fluo/integration/impl/TimestampTrackerIT.java | 12 +-
.../apache/fluo/integration/impl/TransactorIT.java | 8 +-
.../org/apache/fluo/integration/impl/WorkerIT.java | 4 +-
.../apache/fluo/integration/impl/ZKSecretIT.java | 6 +-
.../org/apache/fluo/integration/log/LogIT.java | 32 +++---
.../fluo/mapreduce/FluoEntryInputFormat.java | 13 +--
.../apache/fluo/mapreduce/FluoOutputFormat.java | 13 +--
.../apache/fluo/mapreduce/FluoRowInputFormat.java | 13 +--
.../fluo/mapreduce/it/FluoFileOutputFormatIT.java | 8 +-
pom.xml | 33 +-----
104 files changed, 587 insertions(+), 706 deletions(-)
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
