co.cask.cdap.etl.spark.plugin

Class WrappedWindower

java.lang.Object

co.cask.cdap.etl.api.streaming.Windower

co.cask.cdap.etl.spark.plugin.WrappedWindower

All Implemented Interfaces:

PipelineConfigurable, Serializable

public class WrappedWindower
extends Windower

Wrapper around a Windower that makes sure logging, classloading, and other pipeline capabilities are setup correctly.

See Also:

Serialized Form

Field Summary

Fields inherited from class co.cask.cdap.etl.api.streaming.Windower

PLUGIN_TYPE

Constructor Summary

Constructors

Constructor and Description
WrappedWindower(Windower windower, Caller caller)

Method Summary

Modifier and Type	Method and Description
void	configurePipeline(PipelineConfigurer pipelineConfigurer)
long	getSlideInterval()
long	getWidth()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WrappedWindower

public WrappedWindower(Windower windower,
                       Caller caller)

Method Detail

configurePipeline

public void configurePipeline(PipelineConfigurer pipelineConfigurer)
                       throws IllegalArgumentException

Specified by:

configurePipeline in interface PipelineConfigurable

Overrides:

configurePipeline in class Windower

Throws:

IllegalArgumentException

getWidth

public long getWidth()

Specified by:

getWidth in class Windower

getSlideInterval

public long getSlideInterval()

Specified by:

getSlideInterval in class Windower