public interface JavaStreamingContextFactory
JavaStreamingContext
create()
JavaStreamingContext create()