samza
Mirror of Apache Samza
파일 탐색기
최종 버전 다운로드 (.zip)파일 수가 많아 일부만 표시됩니다. 전체 파일은 위 다운로드 버튼으로 확인해 주세요.
- ci.yml
- check-all.sh
- generate-javadocs.sh
- integration-tests.sh
- merge-pull-request.py
- publish-site.sh
- setup-int-test.sh
- checkstyle-suppressions.xml
- checkstyle.xml
- 2017-08-27-announcing-the-release-of-apache-samza--0.13.1.md
- 2018-01-31-announcing-the-release-of-apache-samza--0.14.0.md
- 2018-05-31-announcing-the-release-of-apache-samza--0.14.1.md
- 2018-07-19-stream_processing-meetup-summary.md
- 2018-09-26-stangeloop-recap.md
- 2018-10-23-stream_processing-meetup-summary.md
- 2018-11-27-announcing-the-release-of-apache-samza--1.0.0.md
- 2019-03-22-announcing-the-release-of-apache-samza--1.1.0.md
- 2019-06-11-announcing-the-release-of-apache-samza--1.2.0.md
- 2019-12-09-announcing-the-release-of-apache-samza--1.3.0.md
- 2020-02-20-announcing-the-release-of-apache-samza--1.3.1.md
- 2020-03-17-announcing-the-release-of-apache-samza--1.4.0.md
- 2020-07-01-announcing-the-release-of-apache-samza--1.5.0.md
- 2020-08-28-announcing-the-release-of-apache-samza--1.5.1.md
- 2021-01-28-announcing-the-release-of-apache-samza--1.6.0.md
- 2023-01-17-announcing-the-release-of-apache-samza--1.8.0.md
- index.md
- TEMPLATE.md
- digitalsmiths.md
- ebay.md
- fortscale.md
- index.md
- intuit.md
- linkedin.md
- netflix.md
- optimizely.md
- redfin.md
- slack.md
- state.md
- TEMPLATE.md
- tripadvisor.md
- uber.md
- aditya-toomula.md
- ajo-thomas.md
- bharath-kumarasubramanian.md
- boris-shkolnik.md
- cameron-lee.md
- chinmay-soman.md
- chris-riccomini.md
- daniel-chen.md
- garry-turkington.md
- hai-lu.md
- jagadish-venkatraman.md
- jake-maes.md
- jakob-homan.md
- jay-kreps.md
- ke-wu.md
- martin-kleppmann.md
- navina-ramesh.md
- prateek-maheshwari.md
- rayman-singh.md
- sanil-jain.md
- shanthoosh-venkataraman.md
- shekhar-sharma.md
- sriram-subramanian.md
- TEMPLATE.md
- wei-song.md
- xinyu-liu.md
- yan-fang.md
- yi-pan.md
- zhijie-shen.md
- local-site-test.sh
- replace-versioned.sh
- footer.html
- main-navigation.html
- blog.html
- case-study.html
- default.html
- page.html
- talks-and-meetups.html
- aug-2016.md
- aug-2017.md
- dec-2017.md
- feb-2015.md
- feb-2016.md
- feb-2017.md
- july-2015.md
- july-2018.md
- jun-2015.md
- jun-2016.md
- june-2018.md
- mar-2018.md
- mar-2019.md
- may-2014.md
- may-2015.md
- may-2016.md
- may-2017.md
- nov-2013.md
- nov-2014.md
- nov-2016.md
- nov-2017.md
- oct-2014.md
- oct-2015.md
- oct-2018.md
- sep-2013.md
- sep-2014.md
- sep-2015.md
- sep-2017.md
- index.html
- cavulus.md
- doubledutch.md
- fortscale.md
- happypancake.md
- improve-digital.md
- intuit.md
- jha.md
- linkedin.md
- metamarkets.md
- mobileaware.md
- movio.md
- netflix.md
- ntent.md
- optimizely.md
- redfin.md
- slack.md
- state.md
- TEMPLATE.md
- tivo.md
- tripadvisor.md
- vintank.md
- vmware.md
- 0.10.md
- 0.11.md
- 0.12.md
- 0.13.md
- 0.14.md
- 0.7.0.md
- 0.8.md
- 0.9.md
- 1.0.0.md
- 1.1.0.md
- 1.2.0.md
- 1.3.0.md
- 1.3.1.md
- 1.4.0.md
- 1.5.0.md
- 1.5.1.md
- 1.6.0.md
- 1.7.0.md
- 1.8.0.md
- older.md
- TEMPLATE.md
- june-2018--bangalore-kafka-group.md
- november-2017-big-data-span-2017.md
- november-2018--totally-awesome-summit.md
- september-21-2017--dataworks-summit-sydney-2017.md
- TEMPLATE.md
- index.html
- committers-old.md
- committers.html
- contact-us.md
- irc.md
- code.md
- coding-guide.md
- contributors-corner.md
- enhancement-proposal.md
- tests.md
- google-fonts.css
- ionicons.min.css
- main.css
- main.new.css
- syntax.css
- fontawesome-webfont.eot
- fontawesome-webfont.svg
- fontawesome-webfont.ttf
- fontawesome-webfont.woff
- FontAwesome.otf
- glyphicons-halflings-regular.eot
- glyphicons-halflings-regular.svg
- glyphicons-halflings-regular.ttf
- glyphicons-halflings-regular.woff
- ionicons.eot
- ionicons.svg
- ionicons.ttf
- ionicons.woff
- ionicons.woff2
- RopaSans-Regular-webfont.woff
- redfin.svg
- trip-advisor.svg
- apple-touch-icon-114x114.png
- apple-touch-icon-120x120.png
- apple-touch-icon-144x144.png
- apple-touch-icon-152x152.png
- apple-touch-icon-57x57.png
- apple-touch-icon-60x60.png
- apple-touch-icon-72x72.png
- apple-touch-icon-76x76.png
- favicon-128.png
- favicon-16x16.png
- favicon-196x196.png
- favicon-32x32.png
- favicon-96x96.png
- favicon.ico
- mstile-144x144.png
- mstile-150x150.png
- mstile-310x150.png
- mstile-310x310.png
- mstile-70x70.png
- linkedin-atc-samza-pipeline.png
- slack-samza-pipeline.png
- samza-arch-detailed.png
- samza-arch1.png
- samza-arch2.png
- samza-arch3.png
- samza-arch4.png
- samza-arch5.png
- samza-arch6.png
- samza-arch7.png
- samza-arch8.png
- table-api-arch.svg
- table-api-class-diagram.png
- table-class-diagram.svg
- table-descriptor-class-diagram.svg
- distributed-execution.png
- fault-tolerance.png
- incremental-checkpointing.png
- state-store.png
- task-assignment.png
- ebay.png
- mupd8-samza.png
- mupd8.png
- checkpointing.svg
- stateful_job.png
- stream_job_and_db.png
- tasks-and-partitions.svg
- visualvm.png
- stream-application.png
- streams-partitions.png
- multi_stage_batch.png
- unified_batch_streaming.png
- coordination-service.png
- dag.graffle
- dag.png
- execution-plan.png
- group-by-example.png
- job.graffle
- job.png
- job_detail.graffle
- job_detail.png
- layered-arch.png
- samza-ecosystem.png
- samza-hadoop.png
- samza-yarn-integration.png
- samza-yarn-kafka-integration.png
- samza_state.graffle
- samza_state.png
- stream.graffle
- stream.png
- data-processing-spectrum-1.png
- data-processing-spectrum-2.png
- data-processing-spectrum-3.png
- jconsole.png
- visualvm.png
- JobsResource.png
- standalone-application.jpg
- am-container-info.png
- am-job-model.png
- am-runtime-configs.png
- am-runtime-metadata.png
- coordinator-internals.png
- samza-am-dashboard.png
- samza-host-affinity.png
- yarn-am-ui.png
- wikipedia-execution-plan.png
- apache-egg-logo.png
- asc.gif
- bg.gif
- desc.gif
- feather.gif
- samza-icon.png
- samza-just-logo-transparent.png
- samza-just-logo.svg
- samza-logo-no-text.png
- samza-logo.png
- samza-logo.svg
- samza-logo@2x.png
- main.new.js
- beam-api.md
- high-level-api.md
- low-level-api.md
- programming-model.md
- samza-sql.md
- table-api.md
- test-framework.md
- architecture-overview.md
- kinesis.md
- introduction.md
- mupd8.md
- spark-streaming.md
- storm.md
- eventhubs.md
- hdfs.md
- kafka.md
- kinesis.md
- overview.md
- checkpointing.md
- coordinator-stream.md
- event-loop.md
- jmx.md
- metrics-table.html
- metrics.md
- samza-container.md
- serialization.md
- state-management.md
- streams.md
- windowing.md
- core-concepts.md
- deployment-model.md
- standalone.md
- yarn.md
- consumer.md
- overview.md
- producer.md
- architecture.md
- background.md
- concepts.md
- configuration-table.html
- configuration.md
- logging.md
- packaging.md
- reprocessing.md
- samza-configurations.md
- web-ui-rest-api.md
- yarn-jobs.md
- kafka.md
- monitoring.md
- security.md
- jobs.md
- tasks.md
- monitors.md
- overview.md
- resource-directory.md
- resources.md
- application-master.md
- isolation.md
- yarn-host-affinity.md
- yarn-resource-localization.md
- yarn-security.md
- index.html
- deploy-samza-job-from-hdfs.md
- deploy-samza-to-CDH.md
- hello-samza-high-level-code.md
- hello-samza-high-level-yarn.md
- hello-samza-high-level-zk.md
- index.md
- remote-debugging-samza.md
- run-hello-samza-without-internet.md
- run-in-multi-node-yarn.md
- samza-async-user-guide.md
- samza-event-hubs-standalone.md
- samza-rest-getting-started.md
- samza-sql.md
- samza-tools.md
- main.less
- non-responsive.less
- variables.less
- index.html
- index.html
- beam.md
- index.md
- samza.md
- index.md
- index.md
- index.md
- beam.md
- index.md
- samza-sql.md
- samza.md
- release-notes.md
- index.html
- _config.yml
- index.md
- Makefile
- README.md
- sitemap.xml
- rat-output-to-html.xsl
- gradle-wrapper.jar
- gradle-wrapper.properties
- buildscript.gradle
- customize.gradle
- dependency-versions-scala-2.11.gradle
- dependency-versions-scala-2.12.gradle
- dependency-versions.gradle
- maven.gradle
- rat.gradle
- release.gradle
- stacktrace.gradle
- InterfaceStability.java
- ApplicationDescriptor.java
- StreamApplicationDescriptor.java
- TaskApplicationDescriptor.java
- ApplicationApiType.java
- SamzaApplication.java
- StreamApplication.java
- TaskApplication.java
- Checkpoint.java
- CheckpointId.java
- CheckpointListener.java
- CheckpointManager.java
- CheckpointManagerFactory.java
- CheckpointV1.java
- CheckpointV2.java
- Config.java
- ConfigException.java
- ConfigFactory.java
- ConfigLoader.java
- ConfigLoaderFactory.java
- ConfigRewriter.java
- JavaTableConfig.java
- MapConfig.java
- SystemStreamPartitionGrouper.java
- SystemStreamPartitionGrouperFactory.java
- SystemStreamPartitionMapper.java
- SystemStreamPartitionMapperFactory.java
- ContainerPlacementMessage.java
- ContainerPlacementRequestMessage.java
- ContainerPlacementResponseMessage.java
- TaskName.java
- ApplicationContainerContext.java
- ApplicationContainerContextFactory.java
- ApplicationTaskContext.java
- ApplicationTaskContextFactory.java
- ContainerContext.java
- Context.java
- ExternalContext.java
- JobContext.java
- TaskContext.java
- JobRestartSignal.java
- JobRestartSignalFactory.java
- JobRestartSignalFactoryContext.java
- DrainMode.java
- DrainNotification.java
- ContainerModel.java
- JobModel.java
- LocalityModel.java
- ProcessorLocality.java
- TaskMode.java
- TaskModel.java
- ApplicationStatus.java
- CommandBuilder.java
- JobCoordinatorMetadata.java
- JobMetadataChange.java
- StreamJob.java
- StreamJobFactory.java
- InMemoryMetadataStore.java
- InMemoryMetadataStoreFactory.java
- MetadataStore.java
- MetadataStoreFactory.java
- Counter.java
- Gauge.java
- Metric.java
- MetricsAccessor.java
- MetricsRegistry.java
- MetricsRegistryWithSource.java
- MetricsReporter.java
- MetricsReporterFactory.java
- MetricsValidationFailureException.java
- MetricsValidator.java
- MetricsVisitor.java
- ReadableMetricsRegistry.java
- ReadableMetricsRegistryListener.java
- Reservoir.java
- SamzaHistogram.java
- SlidingTimeWindowReservoir.java
- Snapshot.java
- Timer.java
- AsyncFlatMapFunction.java
- ClosableFunction.java
- FilterFunction.java
- FlatMapFunction.java
- FoldLeftFunction.java
- InitableFunction.java
- JoinFunction.java
- MapFunction.java
- ScheduledFunction.java
- SinkFunction.java
- StreamTableJoinFunction.java
- SupplierFunction.java
- WatermarkFunction.java
- AnyTrigger.java
- CountTrigger.java
- DurationCharacteristic.java
- FiringType.java
- RepeatingTrigger.java
- TimeBasedTrigger.java
- TimeSinceFirstMessageTrigger.java
- TimeSinceLastMessageTrigger.java
- TimeTrigger.java
- Trigger.java
- Triggers.java
- WindowInternal.java
- WindowType.java
- AccumulationMode.java
- Window.java
- WindowKey.java
- WindowPane.java
- Windows.java
- KV.java
- MessageStream.java
- OutputStream.java
- Scheduler.java
- UpdateMessage.java
- UpdateOptions.java
- ApplicationRunner.java
- LocationId.java
- LocationIdProvider.java
- LocationIdProviderFactory.java
- ProcessorContext.java
- ProcessorIdGenerator.java
- ProcessorLifecycleListener.java
- ProcessorLifecycleListenerFactory.java
- CallbackScheduler.java
- ScheduledCallback.java
- ByteBufferSerde.java
- ByteBufferSerdeFactory.java
- ByteSerde.java
- ByteSerdeFactory.java
- Deserializer.java
- DoubleSerde.java
- DoubleSerdeFactory.java
- IntegerSerde.java
- IntegerSerdeFactory.java
- JsonSerdeV2.java
- JsonSerdeV2Factory.java
- KVSerde.java
- LongSerde.java
- LongSerdeFactory.java
- NoOpSerde.java
- Serde.java
- SerdeFactory.java
- SerializableSerde.java
- SerializableSerdeFactory.java
- Serializer.java
- StringSerde.java
- StringSerdeFactory.java
- UUIDSerde.java
- UUIDSerdeFactory.java
- SamzaSqlFieldType.java
- SqlFieldSchema.java
- SqlSchema.java
- SqlSchemaBuilder.java
- SamzaSqlUdf.java
- SamzaSqlUdfMethod.java
- ScalarUdf.java
- SamzaSqlRelRecord.java
- Startpoint.java
- StartpointOldest.java
- StartpointSpecific.java
- StartpointTimestamp.java
- StartpointUpcoming.java
- StartpointVisitor.java
- DeletedException.java
- RetriableException.java
- BlobStoreManager.java
- BlobStoreManagerFactory.java
- Metadata.java
- ClosableIterator.java
- Entry.java
- KeyValueIterator.java
- KeyValueSnapshot.java
- KeyValueStore.java
- BlobStoreAdminFactory.java
- KafkaChangelogRestoreParams.java
- SideInputsProcessor.java
- SideInputsProcessorFactory.java
- StateBackendAdmin.java
- StateBackendFactory.java
- StorageEngine.java
- StorageEngineFactory.java
- StoreProperties.java
- TaskBackupManager.java
- TaskRestoreManager.java
- BaseMessageChooser.java
- MessageChooser.java
- MessageChooserFactory.java
- ExpandingInputDescriptorProvider.java
- GenericInputDescriptor.java
- GenericOutputDescriptor.java
- GenericSystemDescriptor.java
- InputDescriptor.java
- InputTransformer.java
- OutputDescriptor.java
- OutputDescriptorProvider.java
- SimpleInputDescriptorProvider.java
- StreamDescriptor.java
- StreamExpander.java
- SystemDescriptor.java
- TransformingInputDescriptorProvider.java
- BoundedSSPIterator.java
- ChangelogSSPIterator.java
- ControlMessage.java
- DrainMessage.java
- EndOfStreamMessage.java
- IncomingMessageEnvelope.java
- MessageType.java
- OutgoingMessageEnvelope.java
- StreamSpec.java
- StreamValidationException.java
- SystemAdmin.java
- SystemConsumer.java
- SystemFactory.java
- SystemProducer.java
- SystemProducerException.java
- SystemStream.java
- SystemStreamMetadata.java
- SystemStreamPartition.java
- SystemStreamPartitionIterator.java
- SystemStreamPartitionMatcher.java
- WatermarkMessage.java
- Batch.java
- BatchProvider.java
- Operation.java
- BaseTableDescriptor.java
- CachingTableDescriptor.java
- GuavaCacheTableDescriptor.java
- HybridTableDescriptor.java
- LocalTableDescriptor.java
- RemoteTableDescriptor.java
- TableDescriptor.java
- BaseTableFunction.java
- TableFunction.java
- TablePart.java
- TableRateLimiter.java
- TableReadFunction.java
- TableWriteFunction.java
- TableRetryPolicy.java
- SerdeUtils.java
- AsyncReadWriteUpdateTable.java
- ReadWriteTable.java
- ReadWriteUpdateTable.java
- RecordNotFoundException.java
- Table.java
- TableProvider.java
- TableProviderFactory.java
- AsyncStreamTask.java
- AsyncStreamTaskFactory.java
- ClosableTask.java
- DrainListenerTask.java
- EndOfStreamListenerTask.java
- InitableTask.java
- MessageCollector.java
- StreamOperatorTaskFactory.java
- StreamTask.java
- StreamTaskFactory.java
- TaskCallback.java
- TaskCoordinator.java
- TaskExecutorFactory.java
- TaskFactory.java
- WindowableTask.java
- BlockingEnvelopeMap.java
- Clock.java
- NoOpMetricsRegistry.java
- RateLimiter.java
- SinglePartitionWithoutOffsetsSystemAdmin.java
- TimestampedValue.java
- Partition.java
- SamzaException.java
- TestCheckpointId.java
- TestConfig.java
- TestSamzaHistogram.java
- TestSlidingTimeWindowReservoir.java
- TestSnapshot.java
- TestTimer.java
- TestWindowPane.java
- TestByteBufferSerde.java
- TestByteSerde.java
- TestDoubleSerde.java
- TestIntegerSerde.java
- TestJsonSerdeV2.java
- TestLongSerde.java
- TestSerializableSerde.java
- TestStringSerde.java
- TestUUIDSerde.java
- TestSamzaSqlRelRecord.java
- TestStartpoint.java
- ExampleExpandingInputDescriptor.java
- ExampleExpandingOutputDescriptor.java
- ExampleExpandingSystemDescriptor.java
- ExampleSimpleInputDescriptor.java
- ExampleSimpleOutputDescriptor.java
- ExampleSimpleSystemDescriptor.java
- ExampleTransformingInputDescriptor.java
- ExampleTransformingOutputDescriptor.java
- ExampleTransformingSystemDescriptor.java
- TestExpandingInputDescriptor.java
- TestGenericInputDescriptor.java
- TestGenericSystemDescriptor.java
- TestSimpleInputDescriptor.java
- TestTransformingInputDescriptor.java
- TestBoundedSSPIterator.java
- TestStreamSpec.java
- TestSystemAdmin.java
- TestSystemStreamPartitionIterator.java
- TestTableRateLimiter.java
- TestBaseTableDescriptor.java
- TestBlockingEnvelopeMap.java
- TestNoOpMetricsRegistry.java
- TestSinglePartitionWithoutOffsetsSystemAdmin.java
- KinesisIncomingMessageEnvelope.java
- KinesisRecordProcessor.java
- KinesisRecordProcessorListener.java
- KinesisSystemConsumer.java
- KinesisSystemConsumerOffset.java
- NoAvailablePartitionException.java
- SSPAllocator.java
- KinesisInputDescriptor.java
- KinesisSystemDescriptor.java
- KinesisSystemConsumerMetrics.java
- SamzaHistogram.java
- KinesisAWSCredentialsProvider.java
- KinesisConfig.java
- KinesisSystemAdmin.java
- KinesisSystemFactory.java
- TestKinesisRecordProcessor.java
- TestKinesisSystemConsumer.java
- TestKinesisSystemConsumerOffset.java
- TestSSPAllocator.java
- TestKinesisInputDescriptor.java
- TestKinesisSystemDescriptor.java
- TestKinesisAWSCredentialsProvider.java
- TestKinesisConfig.java
- TestKinesisSystemFactory.java
- AzureCheckpointManager.java
- AzureCheckpointManagerFactory.java
- TaskCheckpointEntity.java
- AzureConfig.java
- BarrierState.java
- JobModelBundle.java
- ProcessorEntity.java
- HeartbeatScheduler.java
- JMVersionUpgradeScheduler.java
- LeaderBarrierCompleteScheduler.java
- LeaderLivenessCheckScheduler.java
- LivenessCheckScheduler.java
- RenewLeaseScheduler.java
- SchedulerStateChangeListener.java
- TaskScheduler.java
- AzureCoordinationUtils.java
- AzureCoordinationUtilsFactory.java
- AzureJobCoordinator.java
- AzureJobCoordinatorFactory.java
- AzureLeaderElector.java
- AzureLock.java
- AzureBlobAvroWriter.java
- AzureBlobAvroWriterFactory.java
- AzureBlobOutputStream.java
- Compression.java
- CompressionFactory.java
- CompressionType.java
- GzipCompression.java
- NoneCompression.java
- AzureBlobSystemProducer.java
- AzureBlobSystemProducerMetrics.java
- AzureBlobWriter.java
- AzureBlobWriterFactory.java
- AzureBlobWriterMetrics.java
- BlobMetadataContext.java
- BlobMetadataGenerator.java
- BlobMetadataGeneratorFactory.java
- NullBlobMetadataGenerator.java
- NullBlobMetadataGeneratorFactory.java
- AzureBlobBasicMetrics.java
- AzureBlobClientBuilder.java
- AzureBlobClientBuilderFactory.java
- AzureBlobConfig.java
- AzureBlobSystemAdmin.java
- AzureBlobSystemFactory.java
- BlobClientBuilder.java
- BlobClientBuilderFactory.java
- EventHubSystemAdmin.java
- PassThroughInterceptor.java
- EventHubIncomingMessageEnvelope.java
- EventHubSystemConsumer.java
- EventHubsInputDescriptor.java
- EventHubsOutputDescriptor.java
- EventHubsSystemDescriptor.java
- AsyncSystemProducer.java
- EventHubSystemProducer.java
- EventHubClientManager.java
- EventHubClientManagerFactory.java
- EventHubConfig.java
- EventHubSystemFactory.java
- Interceptor.java
- SamzaEventHubClientManager.java
- BlobUtils.java
- LeaseBlobManager.java
- TableUtils.java
- AzureClient.java
- AzureException.java
- ITestAzureCheckpointManager.java
- TestAzureBlobAvroWriter.java
- TestAzureBlobOutputStream.java
- TestGzipCompression.java
- TestAzureBlobSystemProducer.java
- TestNullBlobMetadataGenerator.java
- TestEventHubSystemAdmin.java
- ITestEventHubSystemConsumer.java
- TestEventHubSystemConsumer.java
- TestEventHubsInputDescriptor.java
- TestEventHubsOutputDescriptor.java
- TestEventHubsSystemDescriptor.java
- ITestEventHubSystemProducer.java
- SwapFirstLastByteInterceptor.java
- TestEventHubSystemProducer.java
- MockEventData.java
- MockEventHubClientManagerFactory.java
- MockEventHubConfigFactory.java
- TestMetricsRegistry.java
- log4j.xml
- log4j2.xml
- README.md
- ApplicationDescriptorImpl.java
- ApplicationDescriptorUtil.java
- StreamApplicationDescriptorImpl.java
- TaskApplicationDescriptorImpl.java
- ApplicationUtil.java
- LegacyTaskApplication.java
- KafkaChangelogSSPOffset.java
- KafkaStateCheckpointMarker.java
- ContainerPlacementMessageObjectMapper.java
- ContainerPlacementMetadata.java
- ContainerPlacementMetadataStore.java
- ContainerPlacementRequestAllocator.java
- ClusterBasedJobCoordinator.java
- ClusterBasedJobCoordinatorRunner.java
- ClusterResourceManager.java
- ContainerAllocator.java
- ContainerManager.java
- ContainerProcessManager.java
- DefaultApplicationMain.java
- FaultDomain.java
- FaultDomainManager.java
- FaultDomainManagerFactory.java
- FaultDomainType.java
- JobCoordinatorLaunchUtil.java
- ProcessorFailure.java
- ProcessorLaunchException.java
- ResourceManagerFactory.java
- ResourceRequestState.java
- SamzaApplicationState.java
- SamzaResource.java
- SamzaResourceRequest.java
- SamzaResourceStatus.java
- SingleFaultDomainManager.java
- SingleFaultDomainManagerFactory.java
- StandbyContainerManager.java
- StandbyTaskUtil.java
- PropertiesConfigLoader.java
- PropertiesConfigLoaderFactory.java
- ApplicationConfig.java
- BlobStoreConfig.java
- ClusterManagerConfig.java
- DefaultChooserConfig.java
- EnvironmentConfigRewriter.java
- FileSystemCheckpointManagerConfig.java
- InMemorySystemConfig.java
- JobConfig.java
- JobCoordinatorConfig.java
- MetricsConfig.java
- RunLoopConfig.java
- SerializerConfig.java
- ShellCommandConfig.java
- StorageConfig.java
- StreamConfig.java
- SystemConfig.java
- TaskConfig.java
- ZkConfig.java
- DiskQuotaPolicy.java
- DiskQuotaPolicyFactory.java
- DiskSpaceMonitor.java
- NoThrottlingDiskQuotaPolicy.java
- NoThrottlingDiskQuotaPolicyFactory.java
- PollingScanDiskSpaceMonitor.java
- WatermarkDiskQuotaPolicy.java
- WatermarkDiskQuotaPolicyFactory.java
- AllSspToSingleTaskGrouperFactory.java
- GroupByPartition.java
- GroupByPartitionFactory.java
- GroupBySystemStreamPartition.java
- GroupBySystemStreamPartitionFactory.java
- HashSystemStreamPartitionMapper.java
- HashSystemStreamPartitionMapperFactory.java
- SSPGrouperProxy.java
- BalancingTaskNameGrouper.java
- GroupByContainerCount.java
- GroupByContainerCountFactory.java
- GroupByContainerIds.java
- GroupByContainerIdsFactory.java
- GrouperMetadata.java
- GrouperMetadataImpl.java
- SingleContainerGrouperFactory.java
- TaskAssignmentManager.java
- TaskGroup.java
- TaskNameGrouper.java
- TaskNameGrouperFactory.java
- TaskNameGrouperProxy.java
- TaskPartitionAssignmentManager.java
- DefaultSystemStatisticsGetter.java
- OshiBasedStatisticsGetter.java
- PosixCommandBasedStatisticsGetter.java
- ProcessCPUStatistics.java
- StatisticsMonitorImpl.java
- SystemMemoryStatistics.java
- SystemStatistics.java
- SystemStatisticsGetter.java
- SystemStatisticsMonitor.java
- ContainerHeartbeatClient.java
- ContainerHeartbeatMonitor.java
- ContainerHeartbeatResponse.java
- ExecutionContainerIdManager.java
- LocalityManager.java
- RunLoop.java
- RunLoopFactory.java
- RunLoopTask.java
- SamzaContainerListener.java
- SamzaContainerMonitorListener.java
- SamzaContainerStatus.java
- SecurityManager.java
- SecurityManagerFactory.java
- ContainerContextImpl.java
- ContextImpl.java
- InternalTaskContext.java
- JobContextImpl.java
- TaskContextImpl.java
- CoordinatorCommunication.java
- CoordinatorCommunicationContext.java
- CoordinatorToWorkerCommunicationFactory.java
- HttpCoordinatorCommunication.java
- HttpCoordinatorToWorkerCommunicationFactory.java
- JobInfoProvider.java
- JobInfoServingContext.java
- JobModelHttpServlet.java
- NoOpJobRestartSignal.java
- NoOpJobRestartSignalFactory.java
- CoordinatorStreamMetadataStoreFactory.java
- CoordinatorStreamStore.java
- NamespaceAwareCoordinatorStreamStore.java
- LocalityServlet.java
- StaticResourceJobCoordinator.java
- StaticResourceJobCoordinatorFactory.java
- CoordinatorStreamMessage.java
- Delete.java
- SetChangelogMapping.java
- SetConfig.java
- SetContainerHostMapping.java
- SetExecutionEnvContainerIdMapping.java
- SetJobCoordinatorMetadataMessage.java
- SetMigrationMetaMessage.java
- SetTaskContainerMapping.java
- SetTaskModeMapping.java
- SetTaskPartitionMapping.java
- CoordinatorStreamKeySerde.java
- CoordinatorStreamManager.java
- CoordinatorStreamSystemConsumer.java
- CoordinatorStreamSystemProducer.java
- CoordinatorStreamValueSerde.java
- CoordinatorStreamWriter.java
- ClusterMembership.java
- CoordinationConstants.java
- CoordinationUtils.java
- CoordinationUtilsFactory.java
- DistributedLock.java
- InputStreamsDiscoveredException.java
- JobCoordinator.java
- JobCoordinatorFactory.java
- JobCoordinatorListener.java
- JobModelCalculator.java
- JobModelHelper.java
- JobModelMonitors.java
- LeaderElector.java
- LeaderElectorListener.java
- MetadataResourceUtil.java
- NoProcessorJobCoordinatorListener.java
- PartitionChangeException.java
- RunIdGenerator.java
- StreamPartitionCountMonitor.java
- StreamPartitionCountMonitorFactory.java
- StreamRegexMonitor.java
- StreamRegexMonitorFactory.java
- DrainMonitor.java
- DrainNotificationObjectMapper.java
- DrainUtils.java
- EnvironmentVariables.java
- ExecutionPlan.java
- ExecutionPlanner.java
- IntermediateStreamManager.java
- JobGraph.java
- JobGraphJsonGenerator.java
- JobNode.java
- JobNodeConfigurationGenerator.java
- JobPlanner.java
- LocalJobPlanner.java
- OperatorSpecGraphAnalyzer.java
- RemoteJobPlanner.java
- StreamEdge.java
- StreamManager.java
- KeyBasedExecutorService.java
- JobCoordinatorMetadataManager.java
- JobModelUtil.java
- ShellCommandBuilder.java
- LoggingContextHolder.java
- LoggingMetricsReporter.java
- LoggingMetricsReporterConfig.java
- LoggingMetricsReporterFactory.java
- Metrics.java
- MetricsHeader.java
- MetricsSnapshot.java
- MetricsSnapshotReporter.java
- MetricsSnapshotReporterFactory.java
- BaseServerMetrics.java
- JmxMetricsAccessor.java
- JmxUtil.java
- MetricGroup.java
- MetricsBase.java
- MigrationPlan.java
- PartialJoinFunction.java
- TimeSeriesKey.java
- TimeSeriesKeySerde.java
- TimeSeriesStore.java
- TimeSeriesStoreImpl.java
- TimestampedValueSerde.java
- AsyncFlatmapOperatorImpl.java
- BroadcastOperatorImpl.java
- ControlMessageSender.java
- DrainStates.java
- EndOfStreamStates.java
- FlatmapOperatorImpl.java
- InputOperatorImpl.java
- OperatorImpl.java
- OperatorImplGraph.java
- OutputOperatorImpl.java
- PartialJoinOperatorImpl.java
- PartitionByOperatorImpl.java
- SendToTableOperatorImpl.java
- SendToTableWithUpdateOperatorImpl.java
- SinkOperatorImpl.java
- StreamTableJoinOperatorImpl.java
- TriggerKey.java
- TriggerScheduler.java
- WatermarkMetrics.java
- WatermarkStates.java
- WindowOperatorImpl.java
- AsyncFlatMapOperatorSpec.java
- BroadcastOperatorSpec.java
- FilterOperatorSpec.java
- FlatMapOperatorSpec.java
- InputOperatorSpec.java
- JoinOperatorSpec.java
- MapOperatorSpec.java
- MergeOperatorSpec.java
- OperatorSpec.java
- OperatorSpecs.java
- OutputOperatorSpec.java
- OutputStreamImpl.java
- PartitionByOperatorSpec.java
- SendToTableOperatorSpec.java
- SendToTableWithUpdateOperatorSpec.java
- SinkOperatorSpec.java
- StatefulOperatorSpec.java
- StoreDescriptor.java
- StreamOperatorSpec.java
- StreamTableJoinOperatorSpec.java
- WindowOperatorSpec.java
- WindowState.java
- IntermediateMessageStreamImpl.java
- AnyTriggerImpl.java
- Cancellable.java
- CountTriggerImpl.java
- RepeatingTriggerImpl.java
- TimeSinceFirstMessageTriggerImpl.java
- TimeSinceLastMessageTriggerImpl.java
- TimeTriggerImpl.java
- TriggerImpl.java
- TriggerImpls.java
- InternalInMemoryStore.java
- MessageStreamImpl.java
- OperatorSpecGraph.java
- TableImpl.java
- StreamProcessor.java
- ApplicationRunnerMain.java
- ApplicationRunnerOperation.java
- ApplicationRunners.java
- ApplicationRunnerUtil.java
- ClusterBasedProcessorLifecycleListener.java
- ContainerLaunchUtil.java
- DefaultLocationIdProviderFactory.java
- LocalApplicationRunner.java
- LocalContainerRunner.java
- RemoteApplicationRunner.java
- UUIDGenerator.java
- CallbackSchedulerImpl.java
- EpochTimeScheduler.java
- JsonCheckpointV2Mixin.java
- JsonContainerModelMixIn.java
- JsonJobCoordinatorMetadataMixIn.java
- JsonJobModelMixIn.java
- JsonLocalityModelMixIn.java
- JsonProcessorLocalityMixIn.java
- JsonTaskModelMixIn.java
- KafkaStateCheckpointMarkerMixin.java
- SamzaObjectMapper.java
- CheckpointV2Serde.java
- IntermediateMessageSerde.java
- JsonCheckpoint.java
- PassthroughCoordinationUtilsFactory.java
- PassthroughJobCoordinator.java
- PassthroughJobCoordinatorFactory.java
- StartpointFanOutPerTask.java
- StartpointManager.java
- StartpointObjectMapper.java
- DirDiff.java
- JsonDirIndexMixin.java
- JsonFileBlobMixin.java
- JsonFileIndexMixin.java
- JsonFileMetadataMixin.java
- JsonSnapshotIndexMixin.java
- JsonSnapshotMetadataMixin.java
- SnapshotIndexSerde.java
- DirIndex.java
- FileBlob.java
- FileIndex.java
- FileMetadata.java
- SnapshotIndex.java
- SnapshotMetadata.java
- BlobStoreBackupManagerMetrics.java
- BlobStoreRestoreManagerMetrics.java
- BlobStoreUtil.java
- DirDiffUtil.java
- BlobStoreBackupManager.java
- BlobStoreRestoreManager.java
- BlobStoreStateBackendFactory.java
- ChangelogStreamManager.java
- KafkaChangelogStateBackendFactory.java
- NonTransactionalStateTaskRestoreManager.java
- SideInputTask.java
- StateStorageTool.java
- StorageManagerUtil.java
- StorageRecovery.java
- TaskSideInputHandler.java
- TaskSideInputStorageManager.java
- TaskStorageCommitManager.java
- TransactionalStateTaskRestoreManager.java
- DelegatingSystemDescriptor.java
- InMemoryManager.java
- InMemorySystemAdmin.java
- InMemorySystemConsumer.java
- InMemorySystemFactory.java
- InMemorySystemProducer.java
- SystemAdmins.java
- AbstractBatch.java
- AsyncBatchingTable.java
- BatchHandler.java
- BatchingNotSupportedException.java
- BatchMetrics.java
- BatchProcessor.java
- CompactBatch.java
- CompactBatchProvider.java
- CompleteBatch.java
- CompleteBatchProvider.java
- DeleteOperation.java
- GetOperation.java
- PutOperation.java
- TableBatchHandler.java
- UpdateOperation.java
- GuavaCacheTable.java
- GuavaCacheTableProvider.java
- GuavaCacheTableProviderFactory.java
- CachingTable.java
- CachingTableProvider.java
- CachingTableProviderFactory.java
- SupplierGauge.java
- AsyncRateLimitedTable.java
- AsyncRemoteTable.java
- NoOpTableReadFunction.java
- RemoteTable.java
- RemoteTableProvider.java
- RemoteTableProviderFactory.java
- AsyncRetriableTable.java
- FailsafeAdapter.java
- RetryMetrics.java
- TableMetrics.java
- TableMetricsUtil.java
- BaseReadWriteUpdateTable.java
- BaseTableProvider.java
- ReadWriteTableDelegate.java
- TableConfigGenerator.java
- TableManager.java
- AsyncStreamTaskAdapter.java
- CoordinatorRequests.java
- DefaultTaskExecutorFactory.java
- StreamOperatorTask.java
- TaskCallbackFactory.java
- TaskCallbackImpl.java
- TaskCallbackListener.java
- TaskCallbackManager.java
- TaskFactoryUtil.java
- TestClock.java
- TestUtils.java
- BoundedLinkedHashSet.java
- ConfigUtil.java
- DiagnosticsUtil.java
- EmbeddedTaggedRateLimiter.java
- FutureUtil.java
- HighResolutionClock.java
- MathUtil.java
- MetricsReporterLoader.java
- ReflectionUtil.java
- RetryPolicyConfig.java
- SamzaUncaughtExceptionHandler.java
- ShutdownUtil.java
- StreamUtil.java
- SystemClock.java
- SystemHighResolutionClock.java
- ThreadUtil.java
- Throttleable.java
- ThrottlingExecutor.java
- ThrottlingScheduler.java
- Util.java
- ProcessorData.java
- ScheduleAfterDebounceTime.java
- ZkBarrierForVersionUpgrade.java
- ZkBarrierListener.java
- ZkClusterMembership.java
- ZkCoordinationUtils.java
- ZkCoordinationUtilsFactory.java
- ZkDistributedLock.java
- ZkJobCoordinator.java
- ZkJobCoordinatorFactory.java
- ZkJobCoordinatorMetrics.java
- ZkKeyBuilder.java
- ZkLeaderElector.java
- ZkMetadataStore.java
- ZkMetadataStoreFactory.java
- ZkProcessorLatch.java
- ZkSessionMetrics.java
- ZkStringSerializer.java
- ZkUtils.java
- ZkUtilsMetrics.java
- FileSystemCheckpointManager.scala
- CheckpointTool.scala
- OffsetManager.scala
- OffsetManagerMetrics.scala
- PropertiesConfigFactory.scala
- RegExTopicGenerator.scala
- ScalaMapConfig.scala
- SameThreadExecutor.scala
- SamzaContainer.scala
- SamzaContainerMetrics.scala
- TaskInstance.scala
- TaskInstanceExceptionHandler.scala
- TaskInstanceMetrics.scala
- HttpServer.scala
- JobServlet.scala
- CoordinatorStreamWriterCommandLine.scala
- JobModelManager.scala
- Latch.java
- BoundedList.java
- DiagnosticsExceptionEvent.java
- DiagnosticsManager.java
- DiagnosticsStreamMessage.java
- ProcessorStopEvent.java
- ProcessJob.scala
- ProcessJobFactory.scala
- ThreadJob.scala
- ThreadJobFactory.scala
- JobRunner.scala
- JmxReporter.scala
- ContainerProcessManagerMetrics.scala
- JmxServer.scala
- JvmMetrics.scala
- MetricsHelper.scala
- MetricsRegistryMap.scala
- CheckpointV1Serde.scala
- JsonSerde.scala
- MetricsSnapshotSerde.scala
- MetricsSnapshotSerdeV2.java
- MetricsSnapshotSerdeV2Factory.java
- SerdeManager.scala
- ContainerStorageManager.java
- ContainerStorageManagerRestoreUtil.java
- ContainerStorageManagerUtil.java
- KafkaNonTransactionalStateTaskBackupManager.scala
- KafkaTransactionalStateTaskBackupManager.scala
- SideInputsManager.java
- BatchingChooser.scala
- BootstrappingChooser.scala
- DefaultChooser.scala
- RoundRobinChooser.scala
- TieredPriorityChooser.scala
- FileReaderSystemAdmin.scala
- FileReaderSystemConsumer.scala
- FileReaderSystemFactory.scala
- RangeSystemStreamPartitionMatcher.scala
- RegexSystemStreamPartitionMatcher.scala
- SSPMetadataCache.java
- StreamMetadataCache.scala
- SystemConsumers.scala
- SystemConsumersMetrics.scala
- SystemProducers.scala
- SystemProducersMetrics.scala
- ReadableCoordinator.scala
- TaskInstanceCollector.scala
- CommandLine.scala
- CoordinatorStreamConfigFactory.java
- CoordinatorStreamUtil.scala
- DefaultCoordinatorStreamConfigFactory.java
- ExponentialSleepStrategy.scala
- FileUtil.scala
- HttpUtil.scala
- Logging.scala
- ScalaJavaUtil.scala
- TimerUtil.scala
- TestStreamApplicationDescriptorImpl.java
- TestTaskApplicationDescriptorImpl.java
- MockStreamApplication.java
- TestApplicationUtil.java
- TestKafkaChangelogSSPOffset.java
- TestKafkaStateCheckpointMarker.java
- TestContainerPlacementMetadataStore.java
- TestContainerPlacementObjectMapper.java
- MockClusterResourceManager.java
- MockClusterResourceManagerCallback.java
- MockClusterResourceManagerFactory.java
- MockContainerAllocatorWithHostAffinity.java
- MockContainerAllocatorWithoutHostAffinity.java
- MockContainerListener.java
- MockContainerRequestState.java
- MockFaultDomainManager.java
- MockFaultDomainManagerFactory.java
- TestClusterBasedJobCoordinator.java
- TestClusterBasedJobCoordinatorRunner.java
- TestContainerAllocatorWithHostAffinity.java
- TestContainerAllocatorWithoutHostAffinity.java
- TestContainerPlacementActions.java
- TestContainerProcessManager.java
- TestContainerRequestState.java
- TestDefaultApplicationMain.java
- TestJobCoordinatorLaunchUtil.java
- TestStandbyAllocator.java
- TestPropertiesConfigLoader.java
- EnvironmentConfigRewriterTest.java
- TestApplicationConfig.java
- TestFileSystemCheckpointManagerConfig.java
- TestJavaTableConfig.java
- TestJobConfig.java
- TestJobCoordinatorConfig.java
- TestMetricsConfig.java
- TestRunLoopConfig.java
- TestSerializerConfig.java
- TestShellCommandConfig.java
- TestStorageConfig.java
- TestStreamConfig.java
- TestSystemConfig.java
- TestTaskConfig.java
- TestDiskQuotaPolicyEntry.java
- TestPollingScanDiskSpaceMonitor.java
- TestWatermarkDiskQuotaPolicy.java
- TestAllSspToSingleTaskGrouper.java
- TestGroupByPartition.java
- TestGroupByPartitionWithGrouperProxy.java
- TestGroupBySystemStreamPartition.java
- TestGroupBySystemStreamPartitionWithGrouperProxy.java
- TestGroupByContainerCount.java
- TestGroupByContainerIds.java
- TestTaskAssignmentManager.java
- TestTaskNameGrouperProxy.java
- TestTaskPartitionAssignmentManager.java
- TestDefaultSystemStatisticsGetter.java
- TestOshiBasedStatisticsGetter.java
- TestStatisticsMonitorImpl.java
- ContainerMocks.java
- TestContainerHeartbeatClient.java
- TestContainerHeartbeatMonitor.java
- TestExecutionContainerIdManager.java
- TestLocalityManager.java
- TestRunLoop.java
- TestSamzaContainerMonitorListener.java
- TestSamzaUncaughtExceptionHandler.java
- MockContext.java
- TestContextImpl.java
- TestInternalTaskContext.java
- TestTaskContextImpl.java
- TestHttpCoordinatorCommunication.java
- TestJobModelHttpServlet.java
- TestJobModelServingContext.java
- CoordinatorStreamStoreTestUtil.java
- TestCoordinatorStreamStore.java
- TestNamespaceAwareCoordinatorStreamStore.java
- TestStaticResourceJobCoordinator.java
- MockCoordinatorStreamSystemFactory.java
- MockCoordinatorStreamWrappedConsumer.java
- TestCoordinatorStreamMessage.java
- TestCoordinatorStreamSystemConsumer.java
- TestCoordinatorStreamSystemProducer.java
- TestCoordinatorStreamWriter.java
- JobModelManagerTestUtil.java
- TestJobModelCalculator.java
- TestJobModelHelper.java
- TestJobModelMonitors.java
- TestMetadataResourceUtil.java
- TestNoProcessorJobCoordinatorListener.java
- TestRunIdGenerator.java
- TestDiagnosticsManager.java
- TestDiagnosticsStreamMessage.java
- DrainMonitorTests.java
- DrainNotificationObjectMapperTests.java
- DrainUtilsTests.java
- ExecutionPlannerTestBase.java
- TestExecutionPlanner.java
- TestIntermediateStreamManager.java
- TestJobGraph.java
- TestJobGraphJsonGenerator.java
- TestJobNodeConfigurationGenerator.java
- TestJobPlanner.java
- TestLocalJobPlanner.java
- TestRemoteJobPlanner.java
- TestStreamEdge.java
- TestStreamManager.java
- TestKeyBasedExecutorService.java
- TestJobCoordinatorMetadataManager.java
- TestJobModel.java
- TestJobModelUtil.java
- TestShellCommandBuilder.java
- TestLoggingContextHolder.java
- TestLoggingMetricsReporter.java
- TestLoggingMetricsReporterConfig.java
- TestMetrics.java
- TestMetricsHeader.java
- TestMetricsSnapshot.java
- TestMetricsSnapshotReporter.java
- TestMetricsSnapshotReporterFactory.java
- TestJmxMetricsAccessor.java
- TestMessageEnvelope.java
- TestOutputMessageEnvelope.java
- TestInMemoryStore.java
- TestTimeSeriesKeySerde.java
- TestTimeSeriesStoreImpl.java
- TestTimestampedValueSerde.java
- TestAsyncFlatmapOperatorImpl.java
- TestControlMessageSender.java
- TestEndOfStreamStates.java
- TestFlatmapOperatorImpl.java
- TestInputOperatorImpl.java
- TestOperatorImpl.java
- TestOperatorImplGraph.java
- TestSinkOperatorImpl.java
- TestStreamTableJoinOperatorImpl.java
- TestWatermarkStates.java
- TestWindowOperator.java
- OperatorSpecTestUtils.java
- TestOperatorSpec.java
- TestPartitionByOperatorSpec.java
- TestWindowOperatorSpec.java
- TestJoinOperator.java
- TestMessageStreamImpl.java
- TestOperatorSpecGraph.java
- TestStreamProcessor.java
- MockProcessorIdGenerator.java
- TestApplicationRunnerMain.java
- TestApplicationRunners.java
- TestClusterBasedProcessorLifecycleListener.java
- TestContainerLaunchUtil.java
- TestLocalApplicationRunner.java
- TestRemoteApplicationRunner.java
- TestCallbackSchedulerImpl.java
- TestEpochTimeScheduler.java
- TestIntermediateMessageSerde.java
- TestMetricsSnapshotSerdeV2.java
- TestSamzaObjectMapper.java
- TestCheckpointV2Serde.java
- TestMetricsSnapshotSerde.java
- StartpointManagerTestUtil.java
- StartpointMock.java
- TestStartpointManager.java
- TestStartpointObjectMapper.java
- TestDirIndex.java
- TestSnapshotIndexSerde.java
- BlobStoreTestUtil.java
- TestBlobStoreUtil.java
- TestDirDiffUtil.java
- TestDirDiffUtilAreSameFile.java
- TestDirDiffUtilMisc.java
- TestBlobStoreBackupManager.java
- TestBlobStoreRestoreManager.java
- MockStorageEngine.java
- MockStorageEngineFactory.java
- TestChangelogStreamManager.java
- TestKafkaChangelogStateBackendFactory.java
- TestStorageRecovery.java
- TestTaskSideInputHandler.java
- TestTaskSideInputStorageManager.java
- TestTaskStorageCommitManager.java
- TestTransactionalStateTaskRestoreManager.java
- TestInMemoryManager.java
- TestInMemorySystem.java
- TestInMemorySystemAdmin.java
- TestInMemorySystemConsumer.java
- TestInMemorySystemProducer.java
- MockSystemFactory.java
- TestSSPMetadataCache.java
- TestBatchProcessor.java
- TestBatchTable.java
- TestCachingTable.java
- TestLocalTableDescriptor.java
- TestAsyncRateLimitedTable.java
- TestRemoteTableDescriptor.java
- TestAsyncRemoteTable.java
- TestRemoteTable.java
- TestAsyncRetriableTable.java
- TestTableRetryPolicy.java
- TestTableConfigGenerator.java
- TestTableManager.java
- IdentityStreamTask.java
- MockAsyncStreamTask.java
- MockStreamTask.java
- TestAsyncStreamAdapter.java
- TestCoordinatorRequests.java
- TestDefaultTaskExecutorFactory.java
- TestStreamOperatorTask.java
- TestTaskCallbackImpl.java
- TestTaskCallbackManager.java
- TestTaskFactoryUtil.java
- EmbeddedZookeeper.java
- FileUtil.java
- MockHttpServer.java
- StreamTestUtils.java
- TestConfigUtil.java
- TestDefaultCoordinatorStreamConfigFactory.java
- TestDiagnosticsUtil.java
- TestEmbeddedTaggedRateLimiter.java
- TestFutureUtil.java
- TestMathUtils.java
- TestReflectionUtil.java
- TestShutdownUtil.java
- TestStreamUtil.java
- TestThrottlingExecutor.java
- TestThrottlingScheduler.java
- TestUtil.java
- TestScheduleAfterDebounceTime.java
- TestZkBarrierForVersionUpgrade.java
- TestZkClusterMembership.java
- TestZkDistributedLock.java
- TestZkJobCoordinator.java
- TestZkKeyBuilder.java
- TestZkLeaderElector.java
- TestZkMetadataStore.java
- TestZkNamespace.java
- TestZkProcessorLatch.java
- TestZkStringSerializer.java
- TestZkUtils.java
- placeholder-jar.jar
- placeholder-txt.json
- placeholder-war.war
- samza-framework-api-classes.txt
- ropa-sans.css
- empty.txt
- moreEnter.txt
- noEnter.txt
- oneEnter.txt
- test-migration-fail.properties
- test.properties
- twoEnter.txt
- TestFileSystemCheckpointManager.scala
- TestCheckpointTool.scala
- TestOffsetManager.scala
- TestPropertiesConfigFactory.scala
- TestRegExTopicGenerator.scala
- TestSamzaContainer.scala
- TestTaskInstance.scala
- TestTaskInstanceExceptionHandler.scala
- TestHttpServer.scala
- TestInputRegexMonitor.java
- TestJobModelManager.scala
- TestStreamPartitionCountMonitor.scala
- TestProcessJob.scala
- TestThreadJob.scala
- TestJobRunner.scala
- TestJmxReporter.scala
- TestBoundedList.java
- TestJmxServer.scala
- TestMetricsHelper.scala
- StreamProcessorTestUtils.scala
- TestCheckpointV1Serde.scala
- TestJsonSerde.scala
- TestSerdeManager.scala
- TestContainerStorageManager.java
- MockMessageChooser.scala
- MockSystemAdmin.scala
- TestBatchingChooser.scala
- TestBootstrappingChooser.scala
- TestDefaultChooser.scala
- TestRoundRobinChooser.scala
- TestTieredPriorityChooser.scala
- TestFileReaderSystemAdmin.scala
- TestFileReaderSystemConsumer.scala
- TestFileReaderSystemFactory.scala
- TestRangeSystemStreamPartitionMatcher.scala
- TestRegexSystemStreamPartitionMatcher.scala
- TestStreamMetadataCache.scala
- TestSystemConsumers.scala
- TestSystemProducers.scala
- TestReadableCoordinator.scala
- TestCoordinatorStreamUtil.scala
- TestExponentialSleepStrategy.scala
- TestFileUtil.scala
- ElasticsearchConfig.java
- ClientFactory.java
- NodeClientFactory.java
- TransportClientFactory.java
- DefaultIndexRequestFactory.java
- IndexRequestFactory.java
- BulkProcessorFactory.java
- ElasticsearchSystemAdmin.java
- ElasticsearchSystemFactory.java
- ElasticsearchSystemProducer.java
- ElasticsearchSystemProducerMetrics.java
- ElasticsearchConfigTest.java
- DefaultIndexRequestFactoryTest.java
- ElasticsearchSystemProducerMetricsTest.java
- ElasticsearchSystemProducerTest.java
- HdfsInputDescriptor.java
- HdfsOutputDescriptor.java
- HdfsSystemDescriptor.java
- DirectoryPartitioner.java
- FileSystemAdapter.java
- HdfsFileSystemAdapter.java
- AvroFileHdfsReader.java
- HdfsReaderFactory.java
- MultiFileHdfsReader.java
- SingleFileHdfsReader.java
- HdfsSystemAdmin.java
- HdfsSystemConsumer.java
- PartitionDescriptorUtil.java
- AvroDataFileHdfsWriter.scala
- BinarySequenceFileHdfsWriter.scala
- Bucketer.scala
- HdfsWriter.scala
- JobNameDateTimeBucketer.scala
- SequenceFileHdfsWriter.scala
- TextSequenceFileHdfsWriter.scala
- HdfsConfig.scala
- HdfsSystemFactory.scala
- HdfsSystemProducer.scala
- HdfsSystemProducerMetrics.scala
- TestHdfsSystemDescriptor.java
- TestDirectoryPartitioner.java
- TestHdfsFileSystemAdapter.java
- TestAvroFileHdfsReader.java
- TestMultiFileHdfsReader.java
- TestHdfsSystemConsumer.java
- TestPartitionDesctiptorUtil.java
- emptyTestFile
- testfile002
- testfile01
- testfile02
- TestEvent.avsc
- samza-hdfs-test-batch-job-avro.properties
- samza-hdfs-test-batch-job-text.properties
- samza-hdfs-test-batch-job.properties
- samza-hdfs-test-job-avro.properties
- samza-hdfs-test-job-text.properties
- samza-hdfs-test-job.properties
- TestHdfsSystemProducerTestSuite.scala
- KafkaCheckpointLogKey.java
- KafkaCheckpointLogKeySerde.java
- KafkaConsumerConfig.java
- KafkaInputDescriptor.java
- KafkaOutputDescriptor.java
- KafkaSystemDescriptor.java
- KafkaConsumerProxy.java
- KafkaConsumerProxyFactory.java
- KafkaStreamSpec.java
- KafkaSystemAdmin.java
- KafkaSystemConsumer.java
- KafkaUtil.java
- KafkaCheckpointManager.scala
- KafkaCheckpointManagerFactory.scala
- KafkaConfig.scala
- KafkaSystemConsumerMetrics.scala
- KafkaSystemFactory.scala
- KafkaSystemProducer.scala
- KafkaSystemProducerMetrics.scala
- TestKafkaCheckpointLogKeySerde.java
- TestKafkaCheckpointManager.java
- TestKafkaConsumerConfig.java
- TestTaskStorageManager.scala
- TestTransactionalStateTaskBackupManager.java
- TestKafkaInputDescriptor.java
- TestKafkaSystemDescriptor.java
- MockKafkaProducer.java
- TestKafkaCheckpointManagerFactory.java
- TestKafkaStreamSpec.java
- TestKafkaSystemAdminJava.java
- TestKafkaSystemAdminWithMock.java
- TestKafkaSystemConsumer.java
- TestKafkaSystemConsumerMetrics.java
- TestKafkaSystemFactoryJava.java
- TestKafkaSystemProducerJava.java
- TestKafkaUtil.java
- TestKafkaConfig.scala
- TestKafkaSystemAdmin.scala
- TestKafkaSystemFactory.scala
- TestKafkaSystemProducer.scala
- BaseKeyValueStorageEngineFactory.java
- LargeMessageSafeStore.java
- LocalTable.java
- LocalTableProvider.java
- LocalTableProviderFactory.java
- RecordTooLargeException.java
- AccessLoggedStore.scala
- AccessLogMessage.scala
- CachedStore.scala
- CachedStoreMetrics.scala
- KeyValueStorageEngine.scala
- KeyValueStorageEngineMetrics.scala
- KeyValueStoreMetrics.scala
- LargeMessageSafeStoreMetrics.scala
- LoggedStore.scala
- LoggedStoreMetrics.scala
- NullSafeKeyValueStore.scala
- SerializedKeyValueStore.scala
- SerializedKeyValueStoreMetrics.scala
- MockKeyValueStorageEngineFactory.java
- TestBaseKeyValueStorageEngineFactory.java
- TestLargeMessageSafeStore.java
- TestLocalTableProvider.java
- TestLocalTableRead.java
- TestLocalTableWrite.java
- MockKeyValueStore.scala
- TestCachedStore.scala
- TestKeyValueStorageEngine.scala
- BaseCouchbaseTableFunction.java
- CouchbaseBucketRegistry.java
- CouchbaseEnvironmentConfigs.java
- CouchbaseTableReadFunction.java
- CouchbaseTableWriteFunction.java
- TestCouchbaseBucketRegistry.java
- TestCouchbaseTableReadFunction.java
- TestCouchbaseTableWriteFunction.java
- InMemoryTableDescriptor.java
- InMemoryKeyValueStorageEngineFactory.java
- InMemoryKeyValueStore.java
- TestInMemoryKeyValueStore.java
- TestInMemoryTableDescriptor.java
- RocksDbTableDescriptor.java
- RocksDbKeyValueReader.java
- RocksDbOptionsHelper.java
- RocksDbReadingTool.java
- RocksDbKeyValueStorageEngineFactory.scala
- RocksDbKeyValueStore.scala
- TestRocksDbTableDescriptor.java
- TestRocksDbKeyValueReader.java
- TestRocksDbKeyValueStoreJava.java
- TestRocksDbKeyValueStore.scala
- Log4jSystemConfig.java
- LoggingEventJsonSerde.java
- LoggingEventJsonSerdeFactory.java
- LoggingEventStringSerde.java
- LoggingEventStringSerdeFactory.java
- JmxAppender.java
- SimpleDiagnosticsAppender.java
- StreamAppender.java
- StreamAppenderMetrics.java
- TestLog4jSystemConfig.java
- TestLoggingEventStringSerde.java
- MockSystemAdmin.java
- MockSystemFactory.java
- MockSystemProducer.java
- TestJmxAppender.java
- TestStreamAppender.java
- log4j.xml
- Log4jSystemConfig.java
- LoggingEventJsonSerde.java
- LoggingEventJsonSerdeFactory.java
- LoggingEventStringSerde.java
- LoggingEventStringSerdeFactory.java
- SimpleDiagnosticsAppender.java
- StreamAppender.java
- StreamAppenderMetrics.java
- TestLoggingEventStringSerde.java
- MockSystemAdmin.java
- MockSystemFactory.java
- MockSystemProducer.java
- TestStreamAppender.java
- log4j2.xml
- run-samza-rest-service.sh
- samza-rest.properties
- JobsClient.java
- LocalStoreMonitor.java
- LocalStoreMonitorConfig.java
- LocalStoreMonitorFactory.java
- LocalStoreMonitorMetrics.java
- Monitor.java
- MonitorConfig.java
- MonitorFactory.java
- MonitorLoader.java
- SamzaMonitorService.java
- YarnApplicationInfo.java
- Job.java
- JobStatus.java
- Partition.java
- Task.java
- InstallationFinder.java
- InstallationRecord.java
- SimpleInstallationFinder.java
- AbstractJobProxy.java
- JobInstance.java
- JobProxy.java
- JobProxyFactory.java
- JobStatusProvider.java
- ScriptJobProxy.java
- SimpleYarnJobProxy.java
- SimpleYarnJobProxyFactory.java
- YarnRestJobStatusProvider.java
- SamzaTaskProxy.java
- SamzaTaskProxyFactory.java
- TaskProxy.java
- TaskProxyFactory.java
- TaskResourceConfig.java
- BaseResourceConfig.java
- DefaultResourceFactory.java
- JobsResource.java
- JobsResourceConfig.java
- ResourceConstants.java
- ResourceFactory.java
- Responses.java
- TasksResource.java
- YarnJobResourceConfig.java
- ScriptOutputHandler.java
- ScriptPathProvider.java
- ScriptRunner.java
- SamzaRestApplication.java
- SamzaRestConfig.java
- SamzaRestService.java
- log4j.xml
- log4j2.xml
- DummyMonitor.java
- DummyMonitorFactory.java
- ExceptionThrowingMonitor.java
- ExceptionThrowingMonitorFactory.java
- MockMonitorFactory.java
- TestLocalStoreMonitor.java
- TestMonitorService.java
- TestYarnRestJobStatusProvider.java
- MockInstallationFinder.java
- MockJobProxy.java
- MockJobProxyFactory.java
- MockJobStatusProvider.java
- MockResourceFactory.java
- MockTaskProxy.java
- MockTaskProxyFactory.java
- BaseJerseyTest.java
- TestJobsResource.java
- TestTasksResource.java
- TestSamzaRestService.java
- src.xml
- checkpoint-tool.sh
- kill-all.sh
- kill-yarn-job-by-name.sh
- kill-yarn-job.sh
- list-yarn-job.sh
- read-rocksdb-tool.sh
- run-app.sh
- run-class.sh
- run-container.sh
- run-coordinator-stream-writer.sh
- run-framework-class.sh
- run-jc.sh
- run-job.sh
- stat-yarn-job.sh
- state-storage-tool.sh
- validate-yarn-job.sh
- log4j-console.xml
- log4j2-console.xml
- d3.v3.min.js
- dagre-d3.min.js
- planToDagre.js
- plan.html
- AvroRelConverter.java
- AvroRelConverterFactory.java
- AvroRelSchemaProvider.java
- AvroTypeFactoryImpl.java
- ConfigBasedAvroRelSchemaProviderFactory.java
- Expression.java
- RexToJavaCompiler.java
- SamzaSqlExecutionContext.java
- SamzaSqlRelMessage.java
- SamzaSqlRelMsgMetadata.java
- SamzaSqlDslConverter.java
- SamzaSqlDslConverterFactory.java
- BuildOutputRecordUdf.java
- ConvertToStringUdf.java
- FlattenUdf.java
- GetNestedFieldUdf.java
- GetSqlFieldUdf.java
- RegexMatchUdf.java
- ConfigBasedIOResolverFactory.java
- ConfigBasedUdfResolver.java
- DslConverter.java
- DslConverterFactory.java
- RelSchemaProvider.java
- RelSchemaProviderFactory.java
- SamzaRelConverter.java
- SamzaRelConverterFactory.java
- SamzaRelTableKeyConverter.java
- SamzaRelTableKeyConverterFactory.java
- SamzaSqlDriver.java
- SamzaSqlJavaTypeFactoryImpl.java
- SqlIOConfig.java
- SqlIOResolver.java
- SqlIOResolverFactory.java
- UdfMetadata.java
- UdfResolver.java
- Checker.java
- QueryPlanner.java
- RelSchemaConverter.java
- SamzaSqlFilterRemoteJoinRule.java
- SamzaSqlOperatorTable.java
- SamzaSqlScalarFunctionImpl.java
- SamzaSqlUdfOperatorTable.java
- SamzaSqlValidator.java
- SamzaSqlValidatorException.java
- SamzaSqlApplication.java
- SamzaSqlApplicationConfig.java
- SamzaSqlApplicationContext.java
- SamzaSqlApplicationRunner.java
- SamzaSqlRelMessageSerdeFactory.java
- SamzaSqlRelRecordSerdeFactory.java
- FilterTranslator.java
- JoinInputNode.java
- JoinTranslator.java
- LogicalAggregateTranslator.java
- ProjectTranslator.java
- QueryTranslator.java
- SamzaSqlLocalTableJoinFunction.java
- SamzaSqlRemoteTableJoinFunction.java
- SamzaSqlTableJoinFunction.java
- ScanTranslator.java
- TranslatorConstants.java
- TranslatorContext.java
- TranslatorInputMetricsMapFunction.java
- TranslatorOutputMetricsMapFunction.java
- ReflectionBasedUdfResolver.java
- JsonUtil.java
- SamzaSqlQueryParser.java
- SqlFileParser.java
- SamzaSqlInputMessage.java
- SamzaSqlInputTransformer.java
- AddressRecord.java
- Company.avsc
- Company.java
- ComplexRecord.avsc
- ComplexRecord.java
- ComplexUnion.avsc
- ComplexUnion.java
- emptySubRecord.java
- EnrichedPageView.avsc
- EnrichedPageView.java
- Kind.java
- MyFixed.java
- PageView.avsc
- PageView.java
- PageViewCount.avsc
- PageViewCount.java
- PhoneNumber.java
- Profile.avsc
- Profile.java
- SimpleRecord.avsc
- SimpleRecord.java
- StreetNumRecord.java
- SubRecord.java
- TestEnumType.java
- TestAvroRelConversion.java
- TestSamzaSqlRelMessage.java
- TestBuildOutputRecordUdf.java
- TestConvertToStringUdf.java
- TestGetSqlFieldUdf.java
- CheckerTest.java
- TestQueryPlanner.java
- TestSamzaSqlValidator.java
- TestSamzaSqlApplicationConfig.java
- TestSamzaSqlApplicationRunner.java
- TestSamzaSqlRelMessageSerde.java
- TestSamzaSqlRelRecordSerde.java
- ConsoleLoggingSystemFactory.java
- SimpleSystemAdmin.java
- TestAvroSystemFactory.java
- TestFilterTranslator.java
- TestJoinTranslator.java
- TestProjectTranslator.java
- TestQueryTranslator.java
- TestSamzaSqlLocalTableJoinFunction.java
- TestSamzaSqlRemoteTableJoinFunction.java
- TranslatorTestBase.java
- TestReflectionBasedUdfResolver.java
- TestSamzaSqlUdf.java
- MyTestArrayUdf.java
- MyTestObjUdf.java
- MyTestPolyUdf.java
- MyTestUdf.java
- RemoteStoreIOResolverTestFactory.java
- SampleRelConverterFactory.java
- SampleRelTableKeyConverter.java
- SampleRelTableKeyConverterFactory.java
- SampleRelTableKeyConverterTest.java
- SamzaSqlTestConfig.java
- TestMetricsRegistryImpl.java
- TestSamzaSqlFileParser.java
- TestSamzaSqlQueryParser.java
- log4j.xml
- log4j2.xml
- samza-sql-shell-log4j.xml
- shell-defaults.conf
- samza-sql-shell.sh
- CliCommand.java
- CliConstants.java
- CliEnvironment.java
- CliHighlighter.java
- CliShell.java
- CliShellEnvironmentVariableHandler.java
- CliView.java
- Main.java
- QueryResultLogView.java
- CliException.java
- CommandHandlerException.java
- ExecutorException.java
- CliCommandHandler.java
- CliCommandType.java
- CliLoggingSystemFactory.java
- FileSystemAvroRelSchemaProviderFactory.java
- SamzaExecutor.java
- SamzaSqlUdfDisplayInfo.java
- CommandHandler.java
- CommandType.java
- EnvironmentVariableHandler.java
- EnvironmentVariableHandlerImpl.java
- EnvironmentVariableSpecs.java
- ExecutionContext.java
- ExecutionStatus.java
- NonQueryResult.java
- QueryResult.java
- SqlExecutor.java
- SqlFunction.java
- CliUtil.java
- Pair.java
- RandomAccessQueue.java
- SamzaExecutorTest.java
- RandomAccessQueueTest.java
- ProfileChangeStream.avsc
- checker.samza
- emitter.samza
- joiner.samza
- README
- reset.sh
- watcher.samza
- container-performance.properties
- counter.samsa
- kafka-read-write-performance.properties
- kv-perf.properties
- negate-number.properties
- standalone.failure.test.properties
- AdClickEvent.java
- EnrichedAdClickEvent.java
- Member.java
- PageViewCount.java
- PageViewEvent.java
- AppWithGlobalConfigExample.java
- AsyncApplicationExample.java
- BroadcastExample.java
- KeyValueStoreExample.java
- MergeExample.java
- OrderShipmentJoinExample.java
- PageViewCounterExample.java
- RepartitionExample.java
- TaskApplicationExample.java
- WindowExample.java
- MockSystemAdmin.java
- MockSystemConsumer.java
- MockSystemFactory.java
- InMemoryInputDescriptor.java
- InMemoryOutputDescriptor.java
- InMemorySystemDescriptor.java
- MessageStreamAssert.java
- StreamAssert.java
- TestRunner.java
- Checker.java
- Emitter.java
- Joiner.java
- Watcher.java
- LocalApplicationRunnerMain.java
- NegateNumberTask.java
- SimpleStatefulTask.java
- StatePerfTestTask.java
- TestStandaloneIntegrationApplication.java
- downloads.json
- kafka.json
- tests.json
- yarn.json
- zookeeper.json
- yarn-site.xml
- performance_tests.py
- smoke_tests.py
- standalone_failure_tests.py
- util.py
- zk_client.py
- deployment.py
- integration_tests.py
- perf.py
- requirements.txt
- samza_failure_testing.py
- samza_job_yarn_deployer.py
- standalone_deployment.py
- standalone_integration_tests.py
- stream_processor.py
- templates.py
- hello-stateful-world.samza
- log4j2.xml
- TestKeyValuePerformance.scala
- TestPerformanceTask.scala
- CheckpointVersionIntegrationTest.java
- TestStreamProcessorUtil.java
- TestZkStreamProcessor.java
- TestZkStreamProcessorBase.java
- TestZkStreamProcessorFailures.java
- TestZkStreamProcessorSession.java
- BaseStateBackendIntegrationTest.java
- BlobStoreStateBackendIntegrationTest.java
- KafkaNonTransactionalStateIntegrationTest.java
- KafkaTransactionalStateIntegrationTest.java
- TestKeyValueSizeHistogramMetric.java
- TestLargeMessageSafeKeyValueStores.java
- MyStatefulApplication.java
- EndOfStreamIntegrationTest.java
- WatermarkIntegrationTest.java
- DrainHighLevelApiIntegrationTest.java
- DrainLowLevelApiIntegrationTest.java
- AsyncStreamTaskIntegrationTest.java
- BroadcastAssertApp.java
- FaultInjectionTest.java
- MyAsyncStreamTask.java
- MyStreamTestTask.java
- SchedulingTest.java
- StreamApplicationIntegrationTest.java
- StreamApplicationIntegrationTestHarness.java
- StreamTaskIntegrationTest.java
- TestSchedulingApp.java
- TestStreamApplicationIntegrationTestHarness.java
- TestSchedulerFunction.java
- InMemoryIntegrationTestHarness.java
- IntegrationTestHarness.java
- KafkaCheckpointManagerIntegrationTest.java
- AdClick.java
- PageView.java
- UserPageAdClick.java
- RepartitionJoinWindowApp.java
- SessionWindowApp.java
- TestAsyncFlatMap.java
- TestRepartitionJoinWindowApp.java
- TestRepartitionWindowApp.java
- TumblingWindowApp.java
- IdentityStreamTask.java
- SharedContextFactories.java
- StandaloneTestUtils.java
- TestData.java
- .gitignore
- .reviewboardrc
- bootstrap.gradle
- build.gradle
- doap_Samza.rdf
- gradle.properties
- gradlew
- gradlew.bat
- HEADER
- KEYS
- LICENSE
- NOTICE
- README.md
- RELEASE.md
# 설치 가이드
1. 코드 내려받기
git clone https://github.com/apache/samza
깃허브에서 프로젝트 코드 전체를 내 컴퓨터로 내려받습니다.
cd samza
방금 내려받은 프로젝트 폴더 안으로 이동합니다.
2. Gradle (Java/Kotlin)
보통 추천사전 준비물
- Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
- JDK (Java) Java/Kotlin 프로젝트를 빌드/실행하려면 필요합니다.
- Gradle 레포에 포함된 gradlew(Gradle Wrapper)를 쓰면 Gradle을 따로 설치할 필요가 없습니다.
./gradlew clean build
Gradle로 빌드를 진행합니다.
gradle -b bootstrap.gradle
Gradle로 빌드를 진행합니다.
./gradlew -PscalaSuffix=2.12 clean build
Gradle로 빌드를 진행합니다.
./gradlew clean test
Gradle로 빌드를 진행합니다.
./gradlew clean :samza-test:test -Dtest.single=TestStatefulTask
Gradle로 빌드를 진행합니다.
BUILD SUCCESSFUL 메시지가 뜨면 성공입니다. build/ 폴더에 결과물이 생성됩니다.
이 레포의 README에 적힌 실제 명령어를 그대로 가져왔습니다.
3. Python
쉬움사전 준비물
⚠️ 이 프로젝트는 규모가 큰 저장소라, 이 방법이 실제 핵심 제품이 아니라 내부 하위 패키지를 가리키는 것일 수 있습니다. README 전체를 함께 확인해보세요.
pip install -r samza-test/src/main/python/requirements.txt
requirements.txt 등에 명시된 파이썬 라이브러리를 설치합니다.
python <실행할 파일명>.py # README에서 정확한 실행 파일명을 확인하세요
파이썬 스크립트(또는 모듈)를 실행합니다.
에러 메시지 없이 실행되고 터미널에 안내 문구가 출력되면 정상입니다.
// repository documentation
Was this content helpful?
(0 ratings)
