Path	Lines of Code
mantis-runtime/src/main/java/io/mantisrx/runtime/Config.java	50
mantis-runtime/src/main/java/io/mantisrx/runtime/Context.java	72
mantis-runtime/src/main/java/io/mantisrx/runtime/DefaultLifecycleFactory.java	15
mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToGroup.java	79
mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToScalar.java	82
mantis-runtime/src/main/java/io/mantisrx/runtime/Groups.java	28
mantis-runtime/src/main/java/io/mantisrx/runtime/Job.java	41
mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToKey.java	79
mantis-runtime/src/main/java/io/mantisrx/runtime/KeyToScalar.java	71
mantis-runtime/src/main/java/io/mantisrx/runtime/KeyValueStageConfig.java	21
mantis-runtime/src/main/java/io/mantisrx/runtime/KeyedStages.java	30
mantis-runtime/src/main/java/io/mantisrx/runtime/MachineDefinitions.java	12
mantis-runtime/src/main/java/io/mantisrx/runtime/MantisJob.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/MantisJobProvider.java	4
mantis-runtime/src/main/java/io/mantisrx/runtime/Metadata.java	31
mantis-runtime/src/main/java/io/mantisrx/runtime/NettyCodec.java	19
mantis-runtime/src/main/java/io/mantisrx/runtime/PortRequest.java	10
mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarStages.java	35
mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToGroup.java	89
mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToKey.java	81
mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToScalar.java	82
mantis-runtime/src/main/java/io/mantisrx/runtime/SinkHolder.java	23
mantis-runtime/src/main/java/io/mantisrx/runtime/SourceHolder.java	46
mantis-runtime/src/main/java/io/mantisrx/runtime/StageConfig.java	73
mantis-runtime/src/main/java/io/mantisrx/runtime/Stages.java	34
mantis-runtime/src/main/java/io/mantisrx/runtime/WorkerInfo.java	63
mantis-runtime/src/main/java/io/mantisrx/runtime/WorkerMap.java	23
mantis-runtime/src/main/java/io/mantisrx/runtime/command/Command.java	4
mantis-runtime/src/main/java/io/mantisrx/runtime/command/CreateJobDescriptorFile.java	116
mantis-runtime/src/main/java/io/mantisrx/runtime/command/CreateZipFile.java	67
mantis-runtime/src/main/java/io/mantisrx/runtime/command/DescriptorException.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/command/LoadValidateCreate.java	42
mantis-runtime/src/main/java/io/mantisrx/runtime/command/LoadValidateCreateDir.java	62
mantis-runtime/src/main/java/io/mantisrx/runtime/command/LoadValidateCreateZip.java	56
mantis-runtime/src/main/java/io/mantisrx/runtime/command/ReadJobFromJar.java	57
mantis-runtime/src/main/java/io/mantisrx/runtime/command/ReadJobFromJarException.java	10
mantis-runtime/src/main/java/io/mantisrx/runtime/command/ReadJobFromZip.java	65
mantis-runtime/src/main/java/io/mantisrx/runtime/command/ReadJobFromZipException.java	10
mantis-runtime/src/main/java/io/mantisrx/runtime/command/ValidateJob.java	40
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/CollectComputation.java	6
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/Computation.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/GroupComputation.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/GroupToScalarComputation.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/KeyComputation.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/MantisOperatorMerge.java	3
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/ScalarComputation.java	6
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/ScalarComputations.java	14
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/ToGroupComputation.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/ToKeyComputation.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/computation/ToScalarComputation.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/core/Collector.java	12
mantis-runtime/src/main/java/io/mantisrx/runtime/core/KeyedMantisStream.java	12
mantis-runtime/src/main/java/io/mantisrx/runtime/core/KeyedMantisStreamImpl.java	43
mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisGraph.java	31
mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisJobBuilder.java	107
mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisStream.java	22
mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisStreamImpl.java	178
mantis-runtime/src/main/java/io/mantisrx/runtime/core/OperandNode.java	26
mantis-runtime/src/main/java/io/mantisrx/runtime/core/WindowSpec.java	40
mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/FilterFunction.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/FlatMapFunction.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/FunctionCombinator.java	112
mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/KeyByFunction.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/MantisFunction.java	12
mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/MapFunction.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/ReduceFunction.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/SimpleReduceFunction.java	18
mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/WindowFunction.java	10
mantis-runtime/src/main/java/io/mantisrx/runtime/core/sinks/ObservableSinkImpl.java	14
mantis-runtime/src/main/java/io/mantisrx/runtime/core/sinks/SinkFunction.java	4
mantis-runtime/src/main/java/io/mantisrx/runtime/core/sources/ObservableSourceImpl.java	37
mantis-runtime/src/main/java/io/mantisrx/runtime/core/sources/SourceFunction.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/descriptor/JobDescriptor.java	40
mantis-runtime/src/main/java/io/mantisrx/runtime/descriptor/JobInfo.java	44
mantis-runtime/src/main/java/io/mantisrx/runtime/descriptor/MetadataInfo.java	21
mantis-runtime/src/main/java/io/mantisrx/runtime/descriptor/ParameterInfo.java	56
mantis-runtime/src/main/java/io/mantisrx/runtime/descriptor/ResourceRequest.java	3
mantis-runtime/src/main/java/io/mantisrx/runtime/descriptor/StageInfo.java	21
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/IllegalMantisJobException.java	11
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java	339
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/PortSelector.java	4
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/PortSelectorInRange.java	12
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/SinkPublisher.java	99
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/StageExecutors.java	406
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerConsumer.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerConsumerRemoteObservable.java	72
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisher.java	9
mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisherRemoteObservable.java	181
mantis-runtime/src/main/java/io/mantisrx/runtime/lifecycle/Lifecycle.java	4
mantis-runtime/src/main/java/io/mantisrx/runtime/lifecycle/LifecycleNoOp.java	20
mantis-runtime/src/main/java/io/mantisrx/runtime/lifecycle/ServiceLocator.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/lifecycle/Shutdown.java	4
mantis-runtime/src/main/java/io/mantisrx/runtime/lifecycle/ShutdownError.java	4
mantis-runtime/src/main/java/io/mantisrx/runtime/lifecycle/Startup.java	4
mantis-runtime/src/main/java/io/mantisrx/runtime/lifecycle/StartupError.java	10
mantis-runtime/src/main/java/io/mantisrx/runtime/markers/MantisMarker.java	16
mantis-runtime/src/main/java/io/mantisrx/runtime/markers/NetworkMerge.java	22
mantis-runtime/src/main/java/io/mantisrx/runtime/markers/SourceOut.java	22
mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageIn.java	22
mantis-runtime/src/main/java/io/mantisrx/runtime/markers/StageOut.java	22
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterDecoder.java	4
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterDefinition.java	84
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterException.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java	294
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/Parameters.java	38
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java	191
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type/BooleanParameter.java	21
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type/DoubleParameter.java	17
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type/EnumCSVParameter.java	45
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type/EnumParameter.java	25
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type/IntParameter.java	17
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type/LongParameter.java	17
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type/StringParameter.java	22
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/validator/Validation.java	22
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/validator/Validator.java	20
mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/validator/Validators.java	56
mantis-runtime/src/main/java/io/mantisrx/runtime/scheduler/MantisRxSingleThreadScheduler.java	17
mantis-runtime/src/main/java/io/mantisrx/runtime/sink/SelfDocumentingSink.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventRequestHandler.java	283
mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventsSink.java	240
mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sink.java	20
mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java	130
mantis-runtime/src/main/java/io/mantisrx/runtime/sink/predicate/Predicate.java	19
mantis-runtime/src/main/java/io/mantisrx/runtime/source/Index.java	28
mantis-runtime/src/main/java/io/mantisrx/runtime/source/SelfDocumentingSource.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/source/Source.java	19
mantis-runtime/src/main/java/io/mantisrx/runtime/source/Sources.java	54
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/ClientResumePolicies.java	72
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/ClientResumePolicy.java	8
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/ContextualHttpSource.java	63
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/HttpClientFactory.java	6
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/HttpRequestFactory.java	5
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/HttpServerProvider.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/HttpSource.java	65
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/HttpSources.java	61
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/ServerPoller.java	9
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java	105
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/HttpClientFactories.java	89
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/HttpRequestFactories.java	47
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/HttpSourceImpl.java	550
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/OperatorResumeOnCompleted.java	60
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/OperatorResumeOnError.java	60
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/ResumeOnCompletedPolicy.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/ResumeOnErrorPolicy.java	7
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/ServerClientContext.java	34
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/ServerContext.java	20
mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/StaticServerPoller.java	53