Popular Classes
S
ources
-
E
xamples
-
D
iscussions
Project: Flume-Hive
Explorer
Outline
plugins
helloworld
src
java
helloworld
HelloWorldSource.java
HelloWorldSink.java
HelloWorldDecorator.java
src
javatest
com
cloudera
flume
agent
TestFlumeNodeMain.java
TestAckedWALDecorator.java
TestAgentSink.java
durability
TestNaiveFileWALManager.java
TestNaiveFileWALDeco.java
TestConcurrentWALMan.java
TestNaiveFileWALManagerConcurrently.java
TestNaiveFileWALHandles.java
TestNaiveFileWALSource.java
TestFlumeNode.java
TestWriteAheadLogDecorator.java
TestEndToEndAckFailureRecovery.java
TestRPCMechanisms.java
diskfailover
TestDiskFailoverDeco.java
TestDiskFailoverManager.java
TestDiskFailoverBehavior.java
TestDiskFailoverSource.java
TestConcurrentDFOMan.java
TestDiskFailoverBenchmarking.java
TestDiskFailoverAgent.java
MockMasterRPC.java
TestLivenessManager.java
TestAgentCloseNoDeadlock.java
TestLogicalNode.java
DirectMasterRPC.java
TestAgentFailChainSink.java
TestThriftMultiMasterRPC.java
TestAcks.java
TestLogicalNodeManager.java
TestAvroMultiMasterRPC.java
shell
TestFlumeShell.java
TestCommandParser.java
ExampleData.java
master
TestFlumeConfigTranslation.java
TestCommandManager.java
TestMasterAutoUpdatesDFO.java
TestZKClient.java
TestLogicalNodeMapping.java
failover
TestFailChainTranslator.java
TestMasterAutoUpdatesE2E.java
TestThriftAdminServer.java
TestZKBackedConfigStore.java
TestMasterReport.java
logical
TestLogicalConfigManager.java
TestFlumeConfigMaster.java
TestMasterServers.java
TestChokeMapping.java
TestMasterAutoUpdates.java
TestGossipedAckManager.java
availability
TestFailChainManager.java
TestFailChainSink.java
TestAvroAdminServer.java
TestTranslatingConfigurationManager.java
SetupMasterTestEnv.java
TestZooKeeperService.java
TestStatusManager.java
flow
TestFailoverFlowConfigManager.java
TestFlowConfigManager.java
TestLogicalFailoverFlowConfigManager.java
ZooKeeperCounterTest.java
TestMemoryBackedConfigStore.java
reporter
TestHistoryReporter.java
TestHierarchicalReports.java
TestReportEvent.java
server
TestAvroReportServer.java
TestThriftReportServer.java
TestMultiGrep.java
ganglia
TestGangliaSink.java
TestHadoopLogData.java
MasterReportPusherTest.java
TestSimpleRegexReporterBuilder.java
sampler
TestSamplers.java
handlers
endtoend
TestReorderDecorator.java
TestAckChecksumDecos.java
hdfs
TestDFSWrite.java
TestWriteableEvent.java
TestEscapedCustomOutputDfs.java
TestReadLogEvents.java
debug
TestMultiplierDeco.java
TestLatchedDeco.java
ExceptionTwiddleDecorator.java
TestInsistentOpen.java
TestSynthSources.java
TestFileSource.java
TestLazyOpen.java
TestStubbornAppendSink.java
TestChokeDecos.java
TestBloomSetDecos.java
TestBenchmarkDeco.java
syslog
TestSyslogWireExtractor.java
TestSyslogTcpSourceThreads.java
text
TestFileNIO.java
TestTailSource.java
TestTailSourceCursor.java
TestSyslogInputFormat.java
output
TestOutputFormats.java
TestOutputFormatFactory.java
TestApacheInputFormat.java
TestTailDirSource.java
hive
TestHiveNotifyingDfsSink.java
scribe
TestScribeSource.java
batch
TestBatching.java
thrift
ThriftEventAdaptorTest.java
TestThriftSinks.java
TestTStatsTransport.java
TestEventQueue.java
StandardSourceSinkHarnesses.java
console
TestStdinSource.java
TestJLineStdinSource.java
exec
TestExecNioSource.java
TestExecEventSource.java
avro
TestAvroSinks.java
TestAvroSerialize.java
TestAvroDataFile.java
rolling
TestRollSink.java
TestRollRollTags.java
core
TestEvent.java
TestFailOverSink.java
TestSelectMaskDecos.java
TestEventImpl.java
extractors
TestExtractors.java
TestBackOffFailOverSink.java
TestFormatterDecorator.java
connector
TestDirectDriver.java
TestPollingSource.java
collector
TestDiskFailoverThenRoll.java
TestCollectorSource.java
TestCollectorSink.java
util
TestShellRPCAvro.java
TestMockClock.java
TestShellRPCThrift.java
MockClock.java
conf
TestParser.java
TestFactories.java
TestFlumeBuilderFunctional.java
TestFlumePatterns.java
TestPlugins.java
TestFlumeConfiguration.java
TestFlumeBuilder.java
TestFlumeSpecGen.java
TestFlumeConfigData.java
TestPatternMatch.java
TestParserErrorMessages.java
util
TestByteBufferSemantics.java
TestDateTimeSemantics.java
TestDeleteOnExit.java
TestStatusHttpServer.java
BenchmarkHarness.java
consistenthash
TestConsistentHash.java
TestRetryHarness.java
TestReservoirSampler.java
TestExponentialBackoff.java
TestFixedRetryPolicy.java
dirwatcher
TestDirWatcher.java
TestCharset.java
distributed
TestGossipMulticast.java
dk
brics
automaton
TestAutomaton.java
avro-gen-java
com
cloudera
flume
reporter
server
avro
AvroFlumeReport.java
AvroFlumeReportServer.java
handlers
avro
FlumeEventAvroServer.java
AvroFlumeEvent.java
Priority.java
conf
avro
AvroFlumeNodeMap.java
AvroFlumeConfigDataMap.java
FlumeNodeStatusAvro.java
AvroFlumeConfigData.java
AvroFlumeChokeMap.java
FlumeReportAvro.java
AvroFlumeClientServer.java
FlumeNodeState.java
FlumeMasterAdminServerAvro.java
CommandStatusAvro.java
FlumeMasterCommandAvro.java
javaperf
com
cloudera
flume
PerfSamplers.java
PerfSyslogFormats.java
ExamplePerfData.java
agent
BenchmarkAgentDecos.java
BenchmarkBasicDecos.java
PerfHdfsIO.java
PerfReportSinks.java
PerfGrepReportSinks.java
handlers
syslog
PerfSyslogWireExtract.java
PerfDiskIO.java
PerfThriftSinks.java
testio
PerfStringAppends.java
PerfStringTrans.java
ahocorasick
org
arabidopsis
ahocorasick
TestState.java
DenseEdgeList.java
SparseEdgeList.java
TestQueue.java
EdgeList.java
SearchResult.java
Queue.java
AhoCorasick.java
TestAhoCorasick.java
State.java
TimeTrial.java
Searcher.java
TestAll.java
javatest-torture
com
cloudera
flume
agent
FaultyFlumeLocalAgentOOME.java
TestMemoryMonitor.java
master
EvilExhaustConnections.java
faults
MemHog.java
ResourceHog.java
FileHandleHog.java
DiskHog.java
log4j
WrappedSyslogAppender.java
mapreduce
com
cloudera
flume
mapreduce
FlumeDataJob.java
java
com
cloudera
flume
agent
FlumeNodeDaemon.java
AgentFailChainSink.java
FlumeNode.java
durability
WALManager.java
NaiveFileWALDeco.java
WALSource.java
NaiveFileWALManager.java
WALCompletionNotifier.java
WALAckManager.java
LogicalNode.java
diskfailover
NaiveFileFailoverManager.java
DiskFailoverManager.java
DiskFailoverDeco.java
DiskFailoverSource.java
MultiMasterRPC.java
LogicalNodeManager.java
AvroMasterRPC.java
MemoryMonitor.java
ThriftMasterRPC.java
FlumeNodeWALNotifier.java
AgentSink.java
MasterRPC.java
LivenessManager.java
shell
CommandLineException.java
CommandBuilder.java
master
ZKInProcessServer.java
ZooKeeperConfigStore.java
ConfigStore.java
flows
FlowConfigManager.java
StatusManager.java
MasterAckManager.java
GossipedMasterAckManager.java
failover
FailoverConfigurationManager.java
Execable.java
CommandStatus.java
MultiConfigCommand.java
ConfigurationManager.java
commands
GenericCommand.java
CreateLogicalNodeForm.java
RefreshAllCommand.java
DecommissionLogicalNodeForm.java
UnconfigCommand.java
RefreshCommand.java
SetChokeLimitForm.java
UpdateAllCommand.java
UnmapLogicalNodeForm.java
MasterClientServerAvro.java
logical
LogicalNameManager.java
LogicalConfigurationManager.java
ZKClient.java
Command.java
MasterClientServerThrift.java
SaveConfigCommand.java
MasterAdminServerThrift.java
Translator.java
FlumeNodeSpec.java
FlumeMaster.java
TranslatingConfigurationManager.java
MasterClientServer.java
CommandManager.java
ConfigCommand.java
availability
FailoverChainManager.java
ConsistentHashFailoverChainManager.java
FailoverChainSink.java
RandomFailoverChainManager.java
MasterExecException.java
MemoryBackedConfigStore.java
MasterClientRPC.java
MasterAdminServerAvro.java
MasterAdminServer.java
ZooKeeperCounter.java
RPCServer.java
ConfigManager.java
ZooKeeperService.java
LoadConfigCommand.java
watchdog
FlumeWatchdog.java
Watchdog.java
reporter
builder
SimpleRegexReporterBuilder.java
ReporterBuilder.java
MultiGrepReporterBuilder.java
MultiReporter.java
server
ThriftReportServer.java
AvroReportServer.java
MasterReportPusher.java
ReportEvent.java
history
DumbTagger.java
CountHistoryReporter.java
TimelineChartGen.java
HistoryReporter.java
ScheduledHistoryReporter.java
charts
google
GoogleHistogramChartGen.java
GoogleTimelineChartGen.java
GoogleChartPackage.java
ChartPackage.java
ganglia
GangliaSink.java
Reportable.java
ReportManager.java
aggregator
CounterSink.java
AccumulatorSink.java
histogram
MultiGrepReporterSink.java
HistogramChartGen.java
HistogramSink.java
RegexGroupHistogramSink.java
sampler
ReservoirSamplerDeco.java
ProbabilitySampler.java
IntervalSampler.java
package-info.java
handlers
endtoend
ReorderDecorator.java
ValueDecorator.java
CollectorAckListener.java
AckListener.java
AckChecksumChecker.java
AckChecksumInjector.java
hdfs
DFSEventSink.java
SeqfileEventSink.java
EscapedCustomDfsSink.java
SeqfileEventSource.java
WriteableEvent.java
WriteableEventKey.java
CustomDfsSink.java
debug
IntervalFlakeyEventSink.java
FlakeyEventSink.java
MultiplierDecorator.java
LazyOpenSource.java
StubbornAppendSink.java
ChokeInfoData.java
BloomGeneratorDeco.java
Log4jTextFileSource.java
InsistentOpenDecorator.java
NoNlASCIISynthSource.java
InMemoryDecorator.java
SynthSourceRndSize.java
ChokeManager.java
SynthSource.java
NullSink.java
LatchedDecorator.java
AttrSynthSource.java
BloomCheckDecorator.java
TextFileSource.java
BenchmarkInjectDecorator.java
StdinSource.java
TextToCollector.java
NullSource.java
ChokeDecorator.java
LazyOpenDecorator.java
TextReaderSource.java
BenchmarkReportDecorator.java
InsistentAppendDecorator.java
TextFileSink.java
NoNlSynthSource.java
MemorySinkSource.java
DelayDecorator.java
ConsoleEventSink.java
IntervalDroppyEventSink.java
syslog
SyslogTcpSourceThreads.java
SyslogWireExtractor.java
SyslogUdpSource.java
SyslogTcpSink.java
SyslogConsts.java
SyslogTcpSource.java
rpc
RpcSink.java
RpcSource.java
text
SyslogEntryFormat.java
ApacheAccessLogFormat.java
TailSource.java
InputFormat.java
output
DebugOutputFormat.java
AbstractOutputFormat.java
Log4jOutputFormat.java
OutputFormat.java
RawOutputFormat.java
FormatFactory.java
Extractor.java
EventExtractException.java
TailDirSource.java
twitter
TwitterStreamSource.java
hive
MarkerStore.java
HiveNotifyingDfsSink.java
SinkCloseNotifier.java
HiveDirCreatedNotification.java
HiveDirCreatedHandler.java
scribe
ScribeEventSource.java
batch
UnbatchingDecorator.java
GunzipDecorator.java
BatchingDecorator.java
GzipDecorator.java
thrift
PrioritizedThriftEventSource.java
ThriftFlumeEventServerImpl.java
ThriftEventSink.java
ThriftAckedEventSink.java
ThriftEventSource.java
ThriftRawEventSink.java
ThriftEventAdaptor.java
TStatsTransport.java
irc
IrcSource.java
IrcSink.java
console
JLineStdinSource.java
exec
ExecNioSource.java
ExecEventSource.java
log4j
Log4JAppenderEventSink.java
Log4JInjector.java
SeqfileAppender.java
FlumeSeqfileAppender.java
Log4JEventAdaptor.java
avro
FlumeEventAvroServerImpl.java
AvroEventAdaptor.java
AvroEventSink.java
AvroJsonOutputFormat.java
AvroEventSource.java
AvroNativeFileOutputFormat.java
AvroDataFileOutputFormat.java
rolling
RollTrigger.java
ProcessTagger.java
RollSink.java
SizeTrigger.java
Tagger.java
TimeTrigger.java
core
FormatterDecorator.java
DriverListener.java
DemuxSink.java
Driver.java
Attributes.java
MaskDecorator.java
SelectDecorator.java
extractors
RegexExtractor.java
SplitExtractor.java
EventImpl.java
FailOverSink.java
EventSource.java
EventBaseImpl.java
EventSinkDecorator.java
FanOutSink.java
EventUtil.java
FanInSource.java
Event.java
EventException.java
CompositeSink.java
PollingSource.java
BackOffFailOverSink.java
EventSink.java
connector
DirectDriver.java
collector
CollectorSource.java
SequenceFileMerger.java
CollectorSink.java
CopyToHdfs.java
FlumeVersionAnnotation.java
util
AdminRPC.java
SystemInfo.java
FlumeVMInfo.java
AdminRPCAvro.java
ThriftServer.java
FlumeShell.java
AdminRPCThrift.java
conf
FlumeIdException.java
FlumeSpecGen.java
FlumePatterns.java
SourceFactoryImpl.java
RuntimeRecognitionException.java
Context.java
PatternMatch.java
FlumeConfigData.java
LinkedSinkFactory.java
LogicalNodeContext.java
FlumeArgException.java
FlumeBuilder.java
SinkFactoryImpl.java
SourceFactory.java
SinkFactory.java
ReportTestingContext.java
FlumeSpecException.java
FlumeConfiguration.java
VersionInfo.java
util
FileUtil.java
CheckJavaVersion.java
AlwaysRetryPolicy.java
ByteBufferInputStream.java
NetUtils.java
Retryable.java
ReservoirSampler.java
StatusHttpServer.java
Histogram.java
FixedPeriodBackoff.java
CappedExponentialBackoff.java
consistenthash
ConsistentLists.java
MoveHandler.java
MD5HashFunction.java
HashFunction.java
ConsistentHash.java
Benchmark.java
FixedRetryPolicy.java
BackoffPolicy.java
DateUtils.java
CharEncUtils.java
OSUtils.java
RetryHarness.java
Clock.java
bloom
BloomSet.java
ResultRetryable.java
MultipleIOException.java
InputStreamPipe.java
CumulativeCappedExponentialBackoff.java
Cache.java
dirwatcher
DirWatcher.java
DirChangeHandler.java
FileFilter.java
RegexFileFilter.java
Pair.java
ComparablePair.java
ExponentialBackoff.java
distributed
MessageReceiver.java
TCPNodeId.java
GossipMulticast.java
Multicast.java
NodeId.java
Group.java
Message.java
org
apache
thrift
server
TSaneThreadPoolServer.java
transport
TSaneServerSocket.java
hadoop
io
FlushingSequenceFileWriter.java
gen-java
com
cloudera
flume
shell
antlr
FlumeShellLexer.java
FlumeShellParser.java
reporter
server
thrift
ThriftFlumeReport.java
ThriftFlumeReportServer.java
handlers
scribe
FacebookService.java
fb_status.java
scribe.java
LogEntry.java
ResultCode.java
thrift
ThriftFlumeEventServer.java
Priority.java
RawEvent.java
ThriftFlumeEvent.java
EventStatus.java
conf
RuntimeRecognitionException.java
FlumeDeployLexer.java
thrift
FlumeMasterCommandThrift.java
FlumeNodeStatusThrift.java
ThriftFlumeClientServer.java
ThriftFlumeConfigData.java
CommandStatusThrift.java
FlumeNodeState.java
FlumeMasterAdminServer.java
FlumeDeployParser.java
build
src
org
apache
jsp
mastersubmit_jsp.java
command_jsp.java
staticconfig_jsp.java
masterext_jsp.java
mastercommand_jsp.java
masterstaticconfig_jsp.java
flumeagent_jsp.java
extension_jsp.java
allcommands_jsp.java
masterenv_jsp.java
menu_005fagent_jsp.java
environment_jsp.java
flumeconfig_jsp.java
flumereporter_jsp.java
version_jsp.java
menu_jsp.java
fullspec_jsp.java
flumemaster_jsp.java
RegexFileFilter(String regex)
isSelected(File f)
/**
* Licensed to Cloudera, Inc. under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. Cloudera, Inc. licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package
com.cloudera.util.dirwatcher;
import
java.io.File;
import
java.util.regex.Pattern;
/**
* This returns true if the filename (not the directory part) matches the
* specified regular expression.
*
* This class is not thread safe because pattern is not thread safe.
*/
public
class
RegexFileFilter
implements
FileFilter {
Pattern p;
// not thread safe
public
RegexFileFilter
(String regex) {
this
.p = Pattern.compile(regex);
}
@Override
public
boolean
isSelected
(File f) {
return
p.matcher(f.getName()).matches();
}
}