Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id BAE28200C3D for ; Tue, 14 Mar 2017 23:33:54 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id B9866160B89; Tue, 14 Mar 2017 22:33:54 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 70A4D160B63 for ; Tue, 14 Mar 2017 23:33:52 +0100 (CET) Received: (qmail 61349 invoked by uid 500); 14 Mar 2017 22:33:45 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 58490 invoked by uid 99); 14 Mar 2017 22:33:42 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Mar 2017 22:33:42 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 8154CF4B79; Tue, 14 Mar 2017 22:33:41 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: davor@apache.org To: commits@beam.apache.org Date: Tue, 14 Mar 2017 22:34:22 -0000 Message-Id: <8620fb7858a44f908aad8b3262da228f@git.apache.org> In-Reply-To: <76d8237921994d299dfe8de2dcc6f748@git.apache.org> References: <76d8237921994d299dfe8de2dcc6f748@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [43/52] [abbrv] [partial] beam-site git commit: Regenerate website archived-at: Tue, 14 Mar 2017 22:33:54 -0000 http://git-wip-us.apache.org/repos/asf/beam-site/blob/dc04d667/content/documentation/sdks/javadoc/0.6.0/index.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.6.0/index.html b/content/documentation/sdks/javadoc/0.6.0/index.html new file mode 100644 index 0000000..9a22d6c --- /dev/null +++ b/content/documentation/sdks/javadoc/0.6.0/index.html @@ -0,0 +1,75 @@ + + + + + +Generated Documentation (Untitled) + + + + + + + + + +<noscript> +<div>JavaScript is disabled on your browser.</div> +</noscript> +<h2>Frame Alert</h2> +<p>This document is designed to be viewed using the frames feature. If you see this message, you are using a non-frame-capable web client. Link to <a href="overview-summary.html">Non-frame version</a>.</p> + + + http://git-wip-us.apache.org/repos/asf/beam-site/blob/dc04d667/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexPipelineOptions.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexPipelineOptions.html b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexPipelineOptions.html new file mode 100644 index 0000000..f3f5e40 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexPipelineOptions.html @@ -0,0 +1,402 @@ + + + + + +ApexPipelineOptions + + + + + + + + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+
    +
  • Summary: 
    • +
  • Nested | 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+
    +
  • Detail: 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+
+ + +
+ + +
+
org.apache.beam.runners.apex
+

Interface ApexPipelineOptions

+
+
+
+ +
+
+ +
+
+
    +
  • + +
      +
    • + + +

      Method Detail

      + + + +
        +
      • +

        setApplicationName

        +
        void setApplicationName(java.lang.String name)
        +
        • +
      + + + +
        +
      • +

        getApplicationName

        +
        java.lang.String getApplicationName()
        +
        • +
      + + + +
        +
      • +

        setEmbeddedExecution

        +
        void setEmbeddedExecution(boolean embedded)
        +
        • +
      + + + + + + + +
        +
      • +

        setEmbeddedExecutionDebugMode

        +
        void setEmbeddedExecutionDebugMode(boolean embeddedDebug)
        +
        • +
      + + + +
        +
      • +

        isEmbeddedExecutionDebugMode

        +
        @Default.Boolean(value=true)
+boolean isEmbeddedExecutionDebugMode()
        +
        • +
      + + + +
        +
      • +

        setTupleTracingEnabled

        +
        void setTupleTracingEnabled(boolean enabled)
        +
        • +
      + + + + + + + +
        +
      • +

        setRunMillis

        +
        void setRunMillis(long runMillis)
        +
        • +
      + + + + + + + +
        +
      • +

        setConfigFile

        +
        void setConfigFile(java.lang.String name)
        +
        • +
      + + + +
        +
      • +

        getConfigFile

        +
        @Default.String(value="classpath:/beam-runners-apex.properties")
+java.lang.String getConfigFile()
        +
        • +
      +
      • +
    +
    • +
+
+
+ + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+
    +
  • Summary: 
    • +
  • Nested | 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+
    +
  • Detail: 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+
+ + +
+ + + http://git-wip-us.apache.org/repos/asf/beam-site/blob/dc04d667/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunner.CreateApexPCollectionView.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunner.CreateApexPCollectionView.html b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunner.CreateApexPCollectionView.html new file mode 100644 index 0000000..4d395e5 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunner.CreateApexPCollectionView.html @@ -0,0 +1,311 @@ + + + + + +ApexRunner.CreateApexPCollectionView + + + + + + + + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+
    +
  • Summary: 
    • +
  • Nested | 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+
    +
  • Detail: 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+
+ + +
+ + +
+
org.apache.beam.runners.apex
+

Class ApexRunner.CreateApexPCollectionView<ElemT,ViewT>

+
+
+ +
+
    +
  • +
    +
    Type Parameters:
    +
    ElemT - The type of the elements of the input PCollection
    +
    ViewT - The type associated with the PCollectionView used as a side input
    +
    +
    +
    All Implemented Interfaces:
    +
    java.io.Serializable, HasDisplayData
    +
    +
    +
    Enclosing class:
    +
    ApexRunner
    +
    +
    +
    +
    public static class ApexRunner.CreateApexPCollectionView<ElemT,ViewT>
+extends PTransform<PCollection<java.util.List<ElemT>>,PCollectionView<ViewT>>
    +
    Creates a primitive PCollectionView. + +

    For internal use only by runner implementors.

    +
    +
    See Also:
    +
    Serialized Form
    +
    +
    • +
+
+
+ +
+
+
    +
  • + +
      +
    • + + +

      Method Detail

      + + + + + + + +
        +
      • +

        expand

        +
        public PCollectionView<ViewT> expand(PCollection<java.util.List<ElemT>> input)
        +
        Description copied from class: PTransform
        +
        Applies this PTransform on the given InputT, and returns its + Output. + +

        Composite transforms, which are defined in terms of other transforms, + should return the output of one of the composed transforms. Non-composite + transforms, which do not apply any transforms internally, should return + a new unbound output and register evaluators (via backend-specific + registration methods).

        +
        +
        Specified by:
        +
        expand in class PTransform<PCollection<java.util.List<ElemT>>,PCollectionView<ViewT>>
        +
        +
        • +
      +
      • +
    +
    • +
+
+
+ + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+
    +
  • Summary: 
    • +
  • Nested | 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+
    +
  • Detail: 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+
+ + +
+ + + http://git-wip-us.apache.org/repos/asf/beam-site/blob/dc04d667/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunner.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunner.html b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunner.html new file mode 100644 index 0000000..ee9f9a9 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunner.html @@ -0,0 +1,380 @@ + + + + + +ApexRunner + + + + + + + + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+ + +
+ + +
+ + +
+
org.apache.beam.runners.apex
+

Class ApexRunner

+
+
+ +
+
    +
  • +
    +
    +
    public class ApexRunner
+extends PipelineRunner<ApexRunnerResult>
    +
    A PipelineRunner that translates the + pipeline to an Apex DAG and executes it on an Apex cluster. + +

    Currently execution is always in embedded mode, + launch on Hadoop cluster will be added in subsequent iteration.

    +
    • +
+
+
+ +
+
+
    +
  • + +
      +
    • + + +

      Field Detail

      + + + +
        +
      • +

        CLASSPATH_SCHEME

        +
        public static final java.lang.String CLASSPATH_SCHEME
        +
        +
        See Also:
        +
        Constant Field Values
        +
        +
        • +
      + + + +
        +
      • +

        ASSERTION_ERROR

        +
        public static final java.util.concurrent.atomic.AtomicReference<java.lang.AssertionError> ASSERTION_ERROR
        +
        TODO: this isn't thread safe and may cause issues when tests run in parallel + Holds any most resent assertion error that was raised while processing elements. + Used in the unit test driver in embedded mode to propagate the exception.
        +
        • +
      +
      • +
    + + + + +
    • +
+
+
+ + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+ + +
+ + +
+ + + http://git-wip-us.apache.org/repos/asf/beam-site/blob/dc04d667/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunnerRegistrar.Options.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunnerRegistrar.Options.html b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunnerRegistrar.Options.html new file mode 100644 index 0000000..2aefb67 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunnerRegistrar.Options.html @@ -0,0 +1,284 @@ + + + + + +ApexRunnerRegistrar.Options + + + + + + + + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+
    +
  • Summary: 
    • +
  • Nested | 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+ +
+ + +
+ + +
+
org.apache.beam.runners.apex
+

Class ApexRunnerRegistrar.Options

+
+
+
    +
  • java.lang.Object
    • +
  • +
      +
    • org.apache.beam.runners.apex.ApexRunnerRegistrar.Options
      • +
    +
    • +
+
+ +
+
+
    +
  • + +
      +
    • + + +

      Constructor Summary

      + + + + + + + + +
      Constructors 
      Constructor and Description
      Options() 
      +
      • +
    + +
      +
    • + + +

      Method Summary

      + + + + + + + + + + +
      All Methods Instance Methods Concrete Methods 
      Modifier and TypeMethod and Description
      java.lang.Iterable<java.lang.Class<? extends PipelineOptions>>getPipelineOptions() 
      +
        +
      • + + +

        Methods inherited from class java.lang.Object

        +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
        • +
      +
      • +
    +
    • +
+
+
+ +
+
+ + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+
    +
  • Summary: 
    • +
  • Nested | 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+ +
+ + +
+ + + http://git-wip-us.apache.org/repos/asf/beam-site/blob/dc04d667/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunnerRegistrar.Runner.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunnerRegistrar.Runner.html b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunnerRegistrar.Runner.html new file mode 100644 index 0000000..7629947 --- /dev/null +++ b/content/documentation/sdks/javadoc/0.6.0/org/apache/beam/runners/apex/ApexRunnerRegistrar.Runner.html @@ -0,0 +1,288 @@ + + + + + +ApexRunnerRegistrar.Runner + + + + + + + + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+
    +
  • Summary: 
    • +
  • Nested | 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+ +
+ + +
+ + +
+
org.apache.beam.runners.apex
+

Class ApexRunnerRegistrar.Runner

+
+
+
    +
  • java.lang.Object
    • +
  • +
      +
    • org.apache.beam.runners.apex.ApexRunnerRegistrar.Runner
      • +
    +
    • +
+
+ +
+
+
    +
  • + +
      +
    • + + +

      Constructor Summary

      + + + + + + + + +
      Constructors 
      Constructor and Description
      Runner() 
      +
      • +
    + + +
    • +
+
+
+ +
+
+ + +
+ + +
Skip navigation links
+ + + + +
+
+ + + +
+ +
+
+
    +
  • Summary: 
    • +
  • Nested | 
    • +
  • Field | 
    • +
  • Constr | 
    • +
  • Method
    • +
+ +
+ + +
+ + +