Path Lines of Code contrib/fluo-checks.xml 186 contrib/fluo-eclipse-style.xml 337 contrib/fluo-eclipse-template.xml 41 contrib/fluo-intellij-style.xml 249 contrib/reference/google-checks.xml 185 contrib/reference/google-eclipse-style.xml 337 contrib/reference/google-intellij-style.xml 475 modules/accumulo/src/main/java/org/apache/fluo/accumulo/format/FluoFormatter.java 111 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/ColumnBuffer.java 63 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/GarbageCollectionIterator.java 272 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/NotificationHashFilter.java 48 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/NotificationIterator.java 103 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/OpenReadLockIterator.java 96 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/PrewriteIterator.java 198 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/PushbackIterator.java 74 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/RollbackCheckIterator.java 133 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/SnapshotIterator.java 235 modules/accumulo/src/main/java/org/apache/fluo/accumulo/iterators/TimestampSkippingIterator.java 97 modules/accumulo/src/main/java/org/apache/fluo/accumulo/summarizer/FluoCollector.java 74 modules/accumulo/src/main/java/org/apache/fluo/accumulo/summarizer/FluoSummarizer.java 51 modules/accumulo/src/main/java/org/apache/fluo/accumulo/util/AccumuloProps.java 12 modules/accumulo/src/main/java/org/apache/fluo/accumulo/util/ByteArrayUtil.java 129 modules/accumulo/src/main/java/org/apache/fluo/accumulo/util/ColumnConstants.java 10 modules/accumulo/src/main/java/org/apache/fluo/accumulo/util/ColumnType.java 55 modules/accumulo/src/main/java/org/apache/fluo/accumulo/util/LongUtil.java 23 modules/accumulo/src/main/java/org/apache/fluo/accumulo/util/NotificationUtil.java 37 modules/accumulo/src/main/java/org/apache/fluo/accumulo/util/ReadLockUtil.java 22 modules/accumulo/src/main/java/org/apache/fluo/accumulo/util/ZookeeperPath.java 25 modules/accumulo/src/main/java/org/apache/fluo/accumulo/util/ZookeeperUtil.java 50 modules/accumulo/src/main/java/org/apache/fluo/accumulo/values/DelLockValue.java 52 modules/accumulo/src/main/java/org/apache/fluo/accumulo/values/DelReadLockValue.java 33 modules/accumulo/src/main/java/org/apache/fluo/accumulo/values/LockValue.java 81 modules/accumulo/src/main/java/org/apache/fluo/accumulo/values/ReadLockValue.java 48 modules/accumulo/src/main/java/org/apache/fluo/accumulo/values/WriteValue.java 40 modules/api/src/main/java/org/apache/fluo/api/client/AbstractSnapshotBase.java 96 modules/api/src/main/java/org/apache/fluo/api/client/AbstractTransactionBase.java 19 modules/api/src/main/java/org/apache/fluo/api/client/FluoAdmin.java 49 modules/api/src/main/java/org/apache/fluo/api/client/FluoClient.java 14 modules/api/src/main/java/org/apache/fluo/api/client/FluoFactory.java 63 modules/api/src/main/java/org/apache/fluo/api/client/Loader.java 11 modules/api/src/main/java/org/apache/fluo/api/client/LoaderExecutor.java 10 modules/api/src/main/java/org/apache/fluo/api/client/Snapshot.java 5 modules/api/src/main/java/org/apache/fluo/api/client/SnapshotBase.java 47 modules/api/src/main/java/org/apache/fluo/api/client/Transaction.java 7 modules/api/src/main/java/org/apache/fluo/api/client/TransactionBase.java 15 modules/api/src/main/java/org/apache/fluo/api/client/scanner/CellScanner.java 9 modules/api/src/main/java/org/apache/fluo/api/client/scanner/ColumnScanner.java 12 modules/api/src/main/java/org/apache/fluo/api/client/scanner/RowScanner.java 8 modules/api/src/main/java/org/apache/fluo/api/client/scanner/RowScannerBuilder.java 4 modules/api/src/main/java/org/apache/fluo/api/client/scanner/ScannerBuilder.java 36 modules/api/src/main/java/org/apache/fluo/api/config/FluoConfiguration.java 618 modules/api/src/main/java/org/apache/fluo/api/config/ObserverSpecification.java 44 modules/api/src/main/java/org/apache/fluo/api/config/SimpleConfiguration.java 265 modules/api/src/main/java/org/apache/fluo/api/data/Bytes.java 366 modules/api/src/main/java/org/apache/fluo/api/data/Column.java 125 modules/api/src/main/java/org/apache/fluo/api/data/ColumnValue.java 59 modules/api/src/main/java/org/apache/fluo/api/data/RowColumn.java 92 modules/api/src/main/java/org/apache/fluo/api/data/RowColumnValue.java 74 modules/api/src/main/java/org/apache/fluo/api/data/Span.java 315 modules/api/src/main/java/org/apache/fluo/api/exceptions/AlreadySetException.java 12 modules/api/src/main/java/org/apache/fluo/api/exceptions/CommitException.java 10 modules/api/src/main/java/org/apache/fluo/api/exceptions/FluoException.java 16 modules/api/src/main/java/org/apache/fluo/api/metrics/Counter.java 7 modules/api/src/main/java/org/apache/fluo/api/metrics/Histogram.java 4 modules/api/src/main/java/org/apache/fluo/api/metrics/Meter.java 5 modules/api/src/main/java/org/apache/fluo/api/metrics/MetricsReporter.java 7 modules/api/src/main/java/org/apache/fluo/api/metrics/Timer.java 5 modules/api/src/main/java/org/apache/fluo/api/mini/MiniFluo.java 8 modules/api/src/main/java/org/apache/fluo/api/observer/AbstractObserver.java 9 modules/api/src/main/java/org/apache/fluo/api/observer/ColumnProviderRegistry.java 29 modules/api/src/main/java/org/apache/fluo/api/observer/Observer.java 48 modules/api/src/main/java/org/apache/fluo/api/observer/ObserverProvider.java 31 modules/api/src/main/java/org/apache/fluo/api/observer/StringObserver.java 12 modules/api/src/main/java/org/apache/fluo/api/service/FluoOracle.java 3 modules/api/src/main/java/org/apache/fluo/api/service/FluoService.java 5 modules/api/src/main/java/org/apache/fluo/api/service/FluoWorker.java 3 modules/command/src/main/java/org/apache/fluo/command/AppCommand.java 21 modules/command/src/main/java/org/apache/fluo/command/BaseCommand.java 10 modules/command/src/main/java/org/apache/fluo/command/CommandUtil.java 35 modules/command/src/main/java/org/apache/fluo/command/ConfigCommand.java 47 modules/command/src/main/java/org/apache/fluo/command/FluoCommand.java 5 modules/command/src/main/java/org/apache/fluo/command/FluoCommandException.java 16 modules/command/src/main/java/org/apache/fluo/command/FluoConfig.java 20 modules/command/src/main/java/org/apache/fluo/command/FluoExec.java 57 modules/command/src/main/java/org/apache/fluo/command/FluoGetJars.java 51 modules/command/src/main/java/org/apache/fluo/command/FluoInit.java 135 modules/command/src/main/java/org/apache/fluo/command/FluoList.java 70 modules/command/src/main/java/org/apache/fluo/command/FluoOracle.java 18 modules/command/src/main/java/org/apache/fluo/command/FluoProgram.java 51 modules/command/src/main/java/org/apache/fluo/command/FluoRemove.java 20 modules/command/src/main/java/org/apache/fluo/command/FluoScan.java 95 modules/command/src/main/java/org/apache/fluo/command/FluoStatus.java 21 modules/command/src/main/java/org/apache/fluo/command/FluoWait.java 87 modules/command/src/main/java/org/apache/fluo/command/FluoWorker.java 18 modules/command/src/main/spotbugs/exclude-filter.xml 5 modules/core/src/main/java/org/apache/fluo/core/async/AsyncCommitObserver.java 7 modules/core/src/main/java/org/apache/fluo/core/async/AsyncConditionalWriter.java 57 modules/core/src/main/java/org/apache/fluo/core/async/AsyncTransaction.java 8 modules/core/src/main/java/org/apache/fluo/core/async/CommitManager.java 92 modules/core/src/main/java/org/apache/fluo/core/async/SyncCommitObserver.java 61 modules/core/src/main/java/org/apache/fluo/core/client/FluoAdminImpl.java 465 modules/core/src/main/java/org/apache/fluo/core/client/FluoClientImpl.java 95 modules/core/src/main/java/org/apache/fluo/core/client/LoaderExecutorAsyncImpl.java 224 modules/core/src/main/java/org/apache/fluo/core/exceptions/AlreadyAcknowledgedException.java 11 modules/core/src/main/java/org/apache/fluo/core/exceptions/StaleScanException.java 13 modules/core/src/main/java/org/apache/fluo/core/impl/AsyncReader.java 68 modules/core/src/main/java/org/apache/fluo/core/impl/CuratorCnxnListener.java 20 modules/core/src/main/java/org/apache/fluo/core/impl/Environment.java 193 modules/core/src/main/java/org/apache/fluo/core/impl/FluoConfigurationImpl.java 130 modules/core/src/main/java/org/apache/fluo/core/impl/LockResolver.java 245 modules/core/src/main/java/org/apache/fluo/core/impl/Notification.java 64 modules/core/src/main/java/org/apache/fluo/core/impl/ParallelSnapshotScanner.java 170 modules/core/src/main/java/org/apache/fluo/core/impl/PrimaryRowColumn.java 45 modules/core/src/main/java/org/apache/fluo/core/impl/ReadLockSnapshot.java 53 modules/core/src/main/java/org/apache/fluo/core/impl/SharedBatchWriter.java 169 modules/core/src/main/java/org/apache/fluo/core/impl/SharedResources.java 200 modules/core/src/main/java/org/apache/fluo/core/impl/SnapshotScanner.java 184 modules/core/src/main/java/org/apache/fluo/core/impl/TimestampTracker.java 188 modules/core/src/main/java/org/apache/fluo/core/impl/TransactionImpl.java 1220 modules/core/src/main/java/org/apache/fluo/core/impl/TransactorCache.java 85 modules/core/src/main/java/org/apache/fluo/core/impl/TransactorID.java 38 modules/core/src/main/java/org/apache/fluo/core/impl/TransactorNode.java 57 modules/core/src/main/java/org/apache/fluo/core/impl/TxInfo.java 76 modules/core/src/main/java/org/apache/fluo/core/impl/TxInfoCache.java 40 modules/core/src/main/java/org/apache/fluo/core/impl/TxStats.java 132 modules/core/src/main/java/org/apache/fluo/core/impl/TxStatus.java 4 modules/core/src/main/java/org/apache/fluo/core/impl/VisibilityCache.java 51 modules/core/src/main/java/org/apache/fluo/core/impl/scanner/CellScannerImpl.java 49 modules/core/src/main/java/org/apache/fluo/core/impl/scanner/ColumnScannerImpl.java 47 modules/core/src/main/java/org/apache/fluo/core/impl/scanner/RowScannerImpl.java 31 modules/core/src/main/java/org/apache/fluo/core/impl/scanner/ScannerBuilderImpl.java 74 modules/core/src/main/java/org/apache/fluo/core/log/TracingCellScanner.java 28 modules/core/src/main/java/org/apache/fluo/core/log/TracingColumnScanner.java 37 modules/core/src/main/java/org/apache/fluo/core/log/TracingRowScanner.java 21 modules/core/src/main/java/org/apache/fluo/core/log/TracingScannerBuilder.java 71 modules/core/src/main/java/org/apache/fluo/core/log/TracingTransaction.java 285 modules/core/src/main/java/org/apache/fluo/core/metrics/DummyMetricsReporter.java 65 modules/core/src/main/java/org/apache/fluo/core/metrics/MetricNames.java 88 modules/core/src/main/java/org/apache/fluo/core/metrics/MetricsReporterImpl.java 50 modules/core/src/main/java/org/apache/fluo/core/metrics/MetricsUtil.java 53 modules/core/src/main/java/org/apache/fluo/core/metrics/ReporterStarter.java 12 modules/core/src/main/java/org/apache/fluo/core/metrics/ReporterUtil.java 57 modules/core/src/main/java/org/apache/fluo/core/metrics/starters/ConsoleReporterStarter.java 34 modules/core/src/main/java/org/apache/fluo/core/metrics/starters/CsvReporterStarter.java 31 modules/core/src/main/java/org/apache/fluo/core/metrics/starters/GraphiteReporterStarter.java 35 modules/core/src/main/java/org/apache/fluo/core/metrics/starters/JmxReporterStarter.java 30 modules/core/src/main/java/org/apache/fluo/core/metrics/starters/Slf4jReporterStarter.java 30 modules/core/src/main/java/org/apache/fluo/core/metrics/types/CounterImpl.java 24 modules/core/src/main/java/org/apache/fluo/core/metrics/types/HistogramImpl.java 12 modules/core/src/main/java/org/apache/fluo/core/metrics/types/MeterImpl.java 16 modules/core/src/main/java/org/apache/fluo/core/metrics/types/TimerImpl.java 13 modules/core/src/main/java/org/apache/fluo/core/observer/ObserverStore.java 9 modules/core/src/main/java/org/apache/fluo/core/observer/ObserverUtil.java 74 modules/core/src/main/java/org/apache/fluo/core/observer/Observers.java 10 modules/core/src/main/java/org/apache/fluo/core/observer/RegisteredObservers.java 9 modules/core/src/main/java/org/apache/fluo/core/observer/v1/ObserverContext.java 40 modules/core/src/main/java/org/apache/fluo/core/observer/v1/ObserverStoreV1.java 182 modules/core/src/main/java/org/apache/fluo/core/observer/v1/ObserversV1.java 116 modules/core/src/main/java/org/apache/fluo/core/observer/v2/JsonObservedColumn.java 22 modules/core/src/main/java/org/apache/fluo/core/observer/v2/JsonObservers.java 27 modules/core/src/main/java/org/apache/fluo/core/observer/v2/ObserverProviderContextImpl.java 32 modules/core/src/main/java/org/apache/fluo/core/observer/v2/ObserverRegistry.java 78 modules/core/src/main/java/org/apache/fluo/core/observer/v2/ObserverStoreV2.java 116 modules/core/src/main/java/org/apache/fluo/core/observer/v2/ObserversV2.java 45 modules/core/src/main/java/org/apache/fluo/core/oracle/FluoOracleImpl.java 86 modules/core/src/main/java/org/apache/fluo/core/oracle/OracleClient.java 326 modules/core/src/main/java/org/apache/fluo/core/oracle/OracleServer.java 357 modules/core/src/main/java/org/apache/fluo/core/oracle/Stamp.java 21 modules/core/src/main/java/org/apache/fluo/core/thrift/OracleService.java 1713 modules/core/src/main/java/org/apache/fluo/core/thrift/Stamps.java 408 modules/core/src/main/java/org/apache/fluo/core/util/AccumuloUtil.java 16 modules/core/src/main/java/org/apache/fluo/core/util/ByteUtil.java 51 modules/core/src/main/java/org/apache/fluo/core/util/CachedBytesConverter.java 26 modules/core/src/main/java/org/apache/fluo/core/util/CachedColumnConverter.java 69 modules/core/src/main/java/org/apache/fluo/core/util/ColumnUtil.java 93 modules/core/src/main/java/org/apache/fluo/core/util/ConditionalFlutation.java 20 modules/core/src/main/java/org/apache/fluo/core/util/Counter.java 25 modules/core/src/main/java/org/apache/fluo/core/util/CuratorUtil.java 143 modules/core/src/main/java/org/apache/fluo/core/util/DeprecationUtil.java 13 modules/core/src/main/java/org/apache/fluo/core/util/FluoCondition.java 12 modules/core/src/main/java/org/apache/fluo/core/util/FluoExecutors.java 30 modules/core/src/main/java/org/apache/fluo/core/util/FluoThreadFactory.java 22 modules/core/src/main/java/org/apache/fluo/core/util/Flutation.java 31 modules/core/src/main/java/org/apache/fluo/core/util/Halt.java 32 modules/core/src/main/java/org/apache/fluo/core/util/Hex.java 101 modules/core/src/main/java/org/apache/fluo/core/util/HostUtil.java 20 modules/core/src/main/java/org/apache/fluo/core/util/Limit.java 33 modules/core/src/main/java/org/apache/fluo/core/util/NotificationScanner.java 61 modules/core/src/main/java/org/apache/fluo/core/util/OracleServerUtils.java 20 modules/core/src/main/java/org/apache/fluo/core/util/PortUtils.java 20 modules/core/src/main/java/org/apache/fluo/core/util/ScanUtil.java 227 modules/core/src/main/java/org/apache/fluo/core/util/SpanUtil.java 60 modules/core/src/main/java/org/apache/fluo/core/util/UtilWaitThread.java 24 modules/core/src/main/java/org/apache/fluo/core/worker/FluoWorkerImpl.java 84 modules/core/src/main/java/org/apache/fluo/core/worker/NotificationFinder.java 10 modules/core/src/main/java/org/apache/fluo/core/worker/NotificationFinderFactory.java 16 modules/core/src/main/java/org/apache/fluo/core/worker/NotificationProcessor.java 237 modules/core/src/main/java/org/apache/fluo/core/worker/TxResult.java 4 modules/core/src/main/java/org/apache/fluo/core/worker/WorkTaskAsync.java 74 modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionInfo.java 57 modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionInfoChangedException.java 4 modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionManager.java 277 modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/PartitionNotificationFinder.java 53 modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/RangeSet.java 64 modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java 163 modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/SerializedSplits.java 84 modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/TableRange.java 79 modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/TabletData.java 20 modules/core/src/main/spotbugs/exclude-filter.xml 8 modules/core/src/main/thrift/oracle.thrift 9 modules/distribution/src/main/assembly/bin.xml 76 modules/mapreduce/src/main/java/org/apache/fluo/mapreduce/FluoEntryInputFormat.java 124 modules/mapreduce/src/main/java/org/apache/fluo/mapreduce/FluoKeyValue.java 20 modules/mapreduce/src/main/java/org/apache/fluo/mapreduce/FluoKeyValueGenerator.java 89 modules/mapreduce/src/main/java/org/apache/fluo/mapreduce/FluoMutationGenerator.java 51 modules/mapreduce/src/main/java/org/apache/fluo/mapreduce/FluoOutputFormat.java 80 modules/mapreduce/src/main/java/org/apache/fluo/mapreduce/FluoRowInputFormat.java 122 modules/mini/src/main/java/org/apache/fluo/mini/MiniFluoImpl.java 139 modules/mini/src/main/spotbugs/exclude-filter.xml 5