Uses of Class
com.norconex.crawler.core.cluster.pipeline.Pipeline

Packages that use Pipeline

Package	Description
com.norconex.crawler.core.cluster.impl.hazelcast
com.norconex.crawler.core.cluster.impl.hazelcast.pipeline
com.norconex.crawler.core.cluster.impl.memory
com.norconex.crawler.core.cluster.pipeline
com.norconex.crawler.core.cmd.crawl.pipeline

Uses of Pipeline in com.norconex.crawler.core.cluster.impl.hazelcast

Methods in com.norconex.crawler.core.cluster.impl.hazelcast with parameters of type Pipeline

Modifier and Type	Method	Description
static StepRecord	HazelcastUtil.currentPipelineStepRecordOrFirst(HazelcastCluster cluster, Pipeline pipeline)
static boolean	HazelcastUtil.isPipelineTerminated(Pipeline pipeline, StepRecord stepRecord, boolean stopRequested)	Whether a pipeline should be considered "terminated", either by completing all steps (success), or having a non-COMPLETED terminal status on any of the steps (aborting the pipeline), or, having a completed step when stopping was requested.
static String	CacheKeys.pipelineKey(@NonNull HazelcastCluster cluster, @NonNull Pipeline pipeline)
static String	CacheKeys.pipelineWorkerKeyPrefix(@NonNull HazelcastCluster cluster, @NonNull Pipeline pipeline)	The worker key without the node information, constructed as:
static String	CacheKeys.pipelineWorkerNodeKey(@NonNull HazelcastCluster cluster, @NonNull Pipeline pipeline)

Uses of Pipeline in com.norconex.crawler.core.cluster.impl.hazelcast.pipeline

Methods in com.norconex.crawler.core.cluster.impl.hazelcast.pipeline with parameters of type Pipeline

Modifier and Type	Method	Description
CompletableFuture<PipelineResult>	HazelcastPipelineManager.executePipeline(@NonNull Pipeline pipeline)

Constructors in com.norconex.crawler.core.cluster.impl.hazelcast.pipeline with parameters of type Pipeline

Modifier	Constructor	Description
	PipelineCoordinator(HazelcastCluster cluster, Pipeline pipeline)
	PipelineCoordinatorState(HazelcastCluster cluster, Pipeline pipeline)
	PipelineExecution(HazelcastCluster cluster, Pipeline pipeline)
	PipelineTerminationTracker(HazelcastCluster cluster, Pipeline pipeline, PipelineWorkerState state)
	PipelineWorker(@NonNull HazelcastCluster cluster, @NonNull Pipeline pipeline)
	PipelineWorkerState(@NonNull HazelcastCluster cluster, @NonNull Pipeline pipeline, @NonNull Consumer<StepRecord> onNewStepRun)

Uses of Pipeline in com.norconex.crawler.core.cluster.impl.memory

Methods in com.norconex.crawler.core.cluster.impl.memory with parameters of type Pipeline

Modifier and Type	Method	Description
CompletableFuture<PipelineResult>	LocalPipelineManager.executePipeline(Pipeline pipeline)

Uses of Pipeline in com.norconex.crawler.core.cluster.pipeline

Methods in com.norconex.crawler.core.cluster.pipeline with parameters of type Pipeline

Modifier and Type	Method	Description
CompletableFuture<PipelineResult>	PipelineManager.executePipeline(Pipeline pipeline)	Executes a pipeline.

Uses of Pipeline in com.norconex.crawler.core.cmd.crawl.pipeline

Methods in com.norconex.crawler.core.cmd.crawl.pipeline that return Pipeline

Modifier and Type	Method	Description
Pipeline	CrawlerPipelineFactory.create(CrawlerSession session)	Create a crawler pipeline
Pipeline	DefaultCrawlPipelineFactory.create(CrawlerSession session)