개요(Google Cloud Dataflow SDK 1.9.1 API)

자바용 Google Cloud Dataflow SDK 버전 1.9.1

자바용 Google Cloud Dataflow SDK는 데이터 처리 파이프라인을 표현하기 위해 간단하고 세련된 프로그래밍 모델을 제공합니다. 자세한 내용과 시작 가이드는 제품 페이지를 참조하세요.

참조: 설명

패키지 
패키지 설명
com.google.cloud.dataflow.sdk
일괄 및 병렬 스트리밍 데이터 동시 처리 Pipeline을 빌드할 수 있는 간편하고 강력한 모델을 제공합니다.
com.google.cloud.dataflow.sdk.annotations
전체 SDK에 사용되는 주석을 정의합니다.
com.google.cloud.dataflow.sdk.coders
데이터를 바이트 문자열로 인코딩하고 바이트 문자열에서 디코딩하는 방법을 지정할 수 있는 Coders를 정의합니다.
com.google.cloud.dataflow.sdk.coders.protobuf
프로토콜 버퍼 메시지인 ProtoCoderCoder를 정의합니다.
com.google.cloud.dataflow.sdk.io
AvroIO, BigQueryIO, TextIO를 포함하여 일반적인 스토리지 형식을 읽고 쓰기 위한 변환을 정의합니다.
com.google.cloud.dataflow.sdk.io.bigtable
Google Cloud Bigtable에서 읽고 쓰기 위한 변환을 정의합니다.
com.google.cloud.dataflow.sdk.io.datastore
다양한 버전의 Cloud Datastore 클라이언트 라이브러리에서 Google Cloud Datastore에 읽고 쓰기 위한 API를 제공합니다.
com.google.cloud.dataflow.sdk.io.range
위치 기반의 제한된 소스에서 동적 작업 재균등화를 구현하기 위한 스레드 안전성을 갖는 도우미를 제공합니다.
com.google.cloud.dataflow.sdk.options
파이프라인 실행을 구성하는 PipelineOptions를 정의합니다.
com.google.cloud.dataflow.sdk.runners
DirectPipelineRunnerDataflowPipelineRunner를 포함하여 다양한 모드에서 파이프라인을 실행하기 위한 러너를 정의합니다.
com.google.cloud.dataflow.sdk.runners.inprocess
로컬 머신에서 제한 및 제한되지 않은 Pipelines를 실행하는 InProcessPipelineRunner를 정의합니다.
com.google.cloud.dataflow.sdk.testing
Dataflow 파이프라인의 단위 테스트를 위한 유틸리티를 정의합니다.
com.google.cloud.dataflow.sdk.transforms
파이프라인의 데이터를 변환하기 위한 PTransform을 정의합니다.
com.google.cloud.dataflow.sdk.transforms.display
UI 및 진단 도구에 사용된 display data를 제공하는 구성요소에 주석을 추가하기 위한 HasDisplayData를 정의합니다.
com.google.cloud.dataflow.sdk.transforms.join
여러 PCollection을 조인하기 위한 CoGroupByKey 변환을 정의합니다.
com.google.cloud.dataflow.sdk.transforms.windowing
PCollection의 요소를 여러 윈도우로 분할하기 위한 Window 변환, 그리고 해당 요소가 출력 되는 시점을 제어하기 위한 Trigger를 정의합니다.
com.google.cloud.dataflow.sdk.values
Pipeline의 데이터를 표현하기 위한 PCollection 및 기타 클래스를 정의합니다.

자바용 Google Cloud Dataflow SDK는 데이터 처리 파이프라인을 표현하기 위해 간단하고 세련된 프로그래밍 모델을 제공합니다. 자세한 내용과 시작 가이드는 제품 페이지를 참조하세요.

자바용 Google Cloud Dataflow SDK를 사용하는 가장 간단한 방법은 Maven Central Repository에서 출시된 아티팩트 중 하나를 사용하는 것입니다. 각 출시 버전에 대한 자세한 내용은 출시 노트를 참조하세요.

major.minor.incremental 형식을 사용하는 버전 번호는 다음과 같이 증분됩니다.

  • 호환되지 않는 API 변경사항에 대한 주 버전
  • 하위 호환되는 방식으로 추가된 새로운 기능에 대한 부 버전
  • 상위 호환되는 버그 수정에 대한 증분 버전

@Experimental로 표시된 API는 언제든지 변경될 수 있으며 버전 간의 호환성을 보장하지 않습니다.