ORACLE CLOUD

Data Flow actions

20 actions you can wire into a flow, alongside everything else in the Oracle Cloud integration.

Every Data Flow action

  • OCI Data Flow: Cancel StatementCancel an interactive statement running against a Data Flow session run.
  • OCI Data Flow: Change Application CompartmentMove a Data Flow application into a different compartment: the application keeps its OCID, only its compartment placement changes.
  • OCI Data Flow: Create ApplicationCreate a Data Flow application: a reusable Apache Spark job template fixing the driver/executor shapes, executor count, Spark version, language and the object-storage URI of the Spark program.
  • OCI Data Flow: Create Private EndpointCreate a Data Flow private endpoint into a VCN subnet so Spark can reach private resources by their DNS zone names. Returns a work-request id: poll Get Private Endpoint until ACTIVE.
  • OCI Data Flow: Create RunLaunch a run of a Data Flow application: one execution of its Spark job. Optionally override the display name. Returns the run, which starts in ACCEPTED; poll Get Run until it reaches SUCCEEDED or FAILED.
  • OCI Data Flow: Delete ApplicationDelete a Data Flow application by its OCID: its Spark definition is removed and can no longer be run.
  • OCI Data Flow: Delete Private EndpointDelete a Data Flow private endpoint by its OCID: returns a work-request ID that tracks the teardown.
  • OCI Data Flow: Delete RunCancel and delete a Data Flow run by its OCID: the Spark job stops and its resources are released.
  • OCI Data Flow: Get ApplicationFetch a single Data Flow application by its OCID: its language, Spark version, executor sizing and lifecycle state.
  • OCI Data Flow: Get Private EndpointFetch a single Data Flow private endpoint by its OCID: its subnet, DNS zones, host count and lifecycle state.
  • OCI Data Flow: Get RunFetch a single Data Flow run by its OCID: its application, language, lifecycle state and duration.
  • OCI Data Flow: Get Run LogFetch the content of a single named log file from a Data Flow run, returned as text.
  • OCI Data Flow: Get StatementFetch a single interactive statement on a Data Flow session run: its lifecycle state and progress.
  • OCI Data Flow: List ApplicationsList the Data Flow applications in a compartment. Optionally filter by exact display name and cap the page size. Walks pagination up to a safe limit.
  • OCI Data Flow: List Private EndpointsList the Data Flow private endpoints in a compartment. Optionally filter by exact display name or lifecycle state, and cap the page size. Walks pagination up to a safe cap.
  • OCI Data Flow: List RunsList the Spark runs in a compartment. Optionally filter by application, exact display name or lifecycle state, and cap the page size. Walks pagination up to a safe cap.
  • OCI Data Flow: List StatementsList the interactive statements submitted against a Data Flow session run. Optionally filter by lifecycle state. Walks pagination up to a safe cap.
  • OCI Data Flow: Submit StatementSubmit an interactive statement (a block of Spark code) to a running Data Flow SESSION run and return the created statement.
  • OCI Data Flow: Update ApplicationPartially update a Data Flow application: change only the display name or number of executors you supply; blank fields are left unchanged.
  • OCI Data Flow: Update RunPartially update a Data Flow run: change only the maximum duration, SESSION idle timeout or free-form tags you supply; blank fields are left unchanged (a run's display name and other properties are immutable once launched).

Also in Oracle Cloud

Put Data Flow in a flow

These actions sit on the same canvas as every other integration, so a Data Flow step can follow a form, a schedule or a message without any glue code.