Agent skill

Io Connectors

by Kilo-Org in Kilo-Org/kilo-marketplace

Guides development and usage of I/O connectors in Apache Beam.

Apache-2.0Auto-check passedDatabases

Install Io Connectors

skills CLI

$ npx skills add Kilo-Org/kilo-marketplace --skill io-connectors -a claude-code

Project install by default; add -g for ~/.claude/skills/.

GitHub CLI

$ gh skill install Kilo-Org/kilo-marketplace io-connectors --agent claude-code

Project scope by default; add --scope user for a personal install. Needs GitHub CLI 2.90.0 or later (public preview).

Manual copy

$ git clone --depth 1 https://github.com/Kilo-Org/kilo-marketplace.git skills-src && mkdir -p .claude/skills && cp -r skills-src/skills/io-connectors .claude/skills/io-connectors && rm -rf skills-src

Use ~/.claude/skills/ instead of .claude/skills for a personal install. The folder must contain SKILL.md.

Claude Code skills documentation · loads skills from .claude/skills/

Paste into Claude Code

Install the "io-connectors" agent skill from https://github.com/Kilo-Org/kilo-marketplace/tree/main/skills/io-connectors into .claude/skills/io-connectors/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "io-connectors", then confirm the skill loads.

Claude Code copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.

$skill-installer

$skill-installer install https://github.com/Kilo-Org/kilo-marketplace/tree/main/skills/io-connectors

Type this inside Codex. $skill-installer <name> installs a curated skill from openai/skills. The installer writes to $CODEX_HOME/skills (default ~/.codex/skills). Restart Codex if the skill does not show up.

skills CLI

$ npx skills add Kilo-Org/kilo-marketplace --skill io-connectors -a codex

Project install goes to .agents/skills/; add -g for ~/.codex/skills/.

GitHub CLI

$ gh skill install Kilo-Org/kilo-marketplace io-connectors --agent codex

Project scope by default (.agents/skills/); add --scope user for a personal install.

Manual copy

$ git clone --depth 1 https://github.com/Kilo-Org/kilo-marketplace.git skills-src && mkdir -p .agents/skills && cp -r skills-src/skills/io-connectors .agents/skills/io-connectors && rm -rf skills-src

Use ~/.agents/skills/ instead of .agents/skills for a personal install.

Codex skills documentation · loads skills from .agents/skills/

Paste into Codex

Install the "io-connectors" agent skill from https://github.com/Kilo-Org/kilo-marketplace/tree/main/skills/io-connectors into .agents/skills/io-connectors/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "io-connectors", then confirm the skill loads.

Codex copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.

skills CLI

$ npx skills add Kilo-Org/kilo-marketplace --skill io-connectors -a cursor

Project install goes to .agents/skills/; add -g for ~/.cursor/skills/.

GitHub CLI

$ gh skill install Kilo-Org/kilo-marketplace io-connectors --agent cursor

Project scope by default (.agents/skills/); add --scope user for a personal install.

Manual copy

$ git clone --depth 1 https://github.com/Kilo-Org/kilo-marketplace.git skills-src && mkdir -p .cursor/skills && cp -r skills-src/skills/io-connectors .cursor/skills/io-connectors && rm -rf skills-src

Use ~/.cursor/skills/ instead of .cursor/skills for a personal install.

Cursor skills documentation · loads skills from .cursor/skills/, .agents/skills/, .claude/skills/, .codex/skills/

Paste into Cursor

Install the "io-connectors" agent skill from https://github.com/Kilo-Org/kilo-marketplace/tree/main/skills/io-connectors into .cursor/skills/io-connectors/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "io-connectors", then confirm the skill loads.

Cursor copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.

gemini skills install

$ gemini skills install https://github.com/Kilo-Org/kilo-marketplace.git --path skills/io-connectors

--scope user (default) or --scope workspace; --path is the subfolder of the repo that holds the skill; --consent skips the security confirmation prompt.

skills CLI

$ npx skills add Kilo-Org/kilo-marketplace --skill io-connectors -a gemini-cli

Project install goes to .agents/skills/; add -g for ~/.gemini/skills/.

GitHub CLI

$ gh skill install Kilo-Org/kilo-marketplace io-connectors --agent gemini-cli

Project scope by default (.agents/skills/); add --scope user for a personal install.

Manual copy

$ git clone --depth 1 https://github.com/Kilo-Org/kilo-marketplace.git skills-src && mkdir -p .gemini/skills && cp -r skills-src/skills/io-connectors .gemini/skills/io-connectors && rm -rf skills-src

Use ~/.gemini/skills/ instead of .gemini/skills for a personal install, then run /skills reload.

Gemini CLI skills documentation · loads skills from .gemini/skills/, .agents/skills/

Paste into Gemini CLI

Install the "io-connectors" agent skill from https://github.com/Kilo-Org/kilo-marketplace/tree/main/skills/io-connectors into .gemini/skills/io-connectors/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "io-connectors", then confirm the skill loads.

Gemini CLI copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.

GitHub CLI

$ gh skill install Kilo-Org/kilo-marketplace io-connectors

Installs for Copilot at project scope by default; add --scope user for a personal install. Preview a skill first with gh skill preview. Needs GitHub CLI 2.90.0 or later (public preview).

skills CLI

$ npx skills add Kilo-Org/kilo-marketplace --skill io-connectors -a github-copilot

Project install goes to .agents/skills/; add -g for ~/.copilot/skills/.

Manual copy

$ git clone --depth 1 https://github.com/Kilo-Org/kilo-marketplace.git skills-src && mkdir -p .github/skills && cp -r skills-src/skills/io-connectors .github/skills/io-connectors && rm -rf skills-src

Use ~/.copilot/skills/ instead of .github/skills for a personal install. Commit .github/skills so cloud agent and code review can use it.

GitHub Copilot skills documentation · loads skills from .github/skills/, .claude/skills/, .agents/skills/

Paste into GitHub Copilot

Install the "io-connectors" agent skill from https://github.com/Kilo-Org/kilo-marketplace/tree/main/skills/io-connectors into .github/skills/io-connectors/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "io-connectors", then confirm the skill loads.

GitHub Copilot copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.

skills CLI

$ npx skills add Kilo-Org/kilo-marketplace --skill io-connectors -a opencode

OpenCode documents no install command of its own. Project install goes to .agents/skills/; add -g for ~/.config/opencode/skills/.

GitHub CLI

$ gh skill install Kilo-Org/kilo-marketplace io-connectors --agent opencode

Project scope by default (.agents/skills/); add --scope user for a personal install.

Manual copy

$ git clone --depth 1 https://github.com/Kilo-Org/kilo-marketplace.git skills-src && mkdir -p .opencode/skills && cp -r skills-src/skills/io-connectors .opencode/skills/io-connectors && rm -rf skills-src

Use ~/.config/opencode/skills/ instead of .opencode/skills for a personal install.

OpenCode skills documentation · loads skills from .opencode/skills/, .claude/skills/, .agents/skills/

Paste into OpenCode

Install the "io-connectors" agent skill from https://github.com/Kilo-Org/kilo-marketplace/tree/main/skills/io-connectors into .opencode/skills/io-connectors/ in this project. Copy the whole folder (SKILL.md and every file beside it), keep the folder name "io-connectors", then confirm the skill loads.

OpenCode copies the folder itself, the same result as the manual copy. Check what it changed before you commit it.

Facts

Skill name: io-connectors
GitHub stars: 190
Token cost: ~1.3k tokens
SKILL.md length: 244 words
Files: 2
Skills in repo: 86
Repo updated: Sep 28, 2026
First seen: Oct 7, 2026
Licence: Apache-2.0

At a glance

Guides development and usage of I/O connectors in Apache Beam.

Works in 3 steps: Source - Reads data (bounded or unbounded) → Sink - Writes data → Read/Write transforms - User-facing API
Working with I/O connectors
SKILL.md covers Overview, Java I/O Connectors Location, Testing I/O Connectors and Integration Test Framework, plus 7 more sections
Instructions only: no scripts, shell commands, URLs or credentials in SKILL.md

What it does

Io Connectors is an agent skill from Kilo-Org/kilo-marketplace. Guides development and usage of I/O connectors in Apache Beam. Use when working with I/O connectors, creating new connectors, or debugging data source/sink issues.

Its SKILL.md is about 1.3k tokens, which your agent loads only when the skill is triggered. The skill folder holds 1 other file.

It sits in Databases, covering Event-driven systems, Integration testing and Data warehousing. It works with Google Cloud, Python, Apache Kafka and Google BigQuery. The repository describes itself as: Kilo Marketplace - A curated collection of Skills, MCP Servers, and Modes for enhancing AI agent capabilities across the Kilo ecosystem—including Kilo Code (VS Code extension)… The licence is Apache-2.0.

When your agent uses it

Working with I/O connectors
Creating new connectors
Debugging data source/sink issues

Example prompts

“Use the io-connectors skill to guide development and usage of I/O connectors in Apache Beam”
“/io-connectors”

Requirements

Python 3

Workflow steps

3 steps, taken from the first numbered list in SKILL.md.

Source - Reads data (bounded or unbounded)
Sink - Writes data
Read/Write transforms - User-facing API

What it can do on your machine

Read from SKILL.md and the folder at commit ff51758. It shows what the files ask for, not the result of running them.

Tool permissions
Pre-approves nothing: there is no allowed-tools line, so your agent's usual permission prompts apply.
From allowed-tools in the SKILL.md frontmatter.
Runs code
No scripts in the folder and no shell commands in SKILL.md (its code samples are java and bash).
From the folder's file list and the shell code blocks in SKILL.md.
Network
No URLs in SKILL.md.
From URLs in SKILL.md, links to its own repository left out.
Credentials
Names no API keys, tokens, secrets or passwords.
From names ending in _API_KEY, _TOKEN, _SECRET, _KEY or _PASSWORD in SKILL.md.

Context cost

Io Connectors loads about 1.3k tokens when it runs. Until then it costs about 44 tokens; SKILL.md has 244 words of instructions outside code blocks.

Always · name and description, kept in context so the agent knows when to use it: ~44
When it runs · the whole SKILL.md, loaded when a task matches: ~1.3k

Estimates: characters ÷ 4, the usual rule of thumb; real counts depend on the model's tokenizer. Scripts and assets cost tokens only if the agent reads them.

Safety

Auto-check passed

The automated check found no risky patterns in SKILL.md.

Automated static check — not a guarantee. Review scripts before installing. It scans the text of SKILL.md for risky patterns (piping downloads into a shell, reading credential files, hidden Unicode, destructive commands); files beside SKILL.md are not scanned.

SKILL.md

The full file from Kilo-Org/kilo-marketplace at commit ff51758, republished under its Apache-2.0 licence (© Kilo-Org). 244 words, ~1,326 tokens.

Download SKILL.mdSave it as .claude/skills/io-connectors/SKILL.md (or your agent's skills folder). This skill also uses 1 other file; get the full folder from GitHub.

name: io-connectors
description: Guides development and usage of I/O connectors in Apache Beam. Use when working with I/O connectors, creating new connectors, or debugging data source/sink issues.
metadata.category: data

I/O Connectors in Apache Beam

Overview

I/O connectors enable reading from and writing to external data sources. Beam provides 51+ Java I/O connectors and several Python connectors.

Java I/O Connectors Location

sdks/java/io/

Available Connectors

Category	Connectors
Cloud Storage	google-cloud-platform (BigQuery, Bigtable, Spanner, Pub/Sub, GCS), amazon-web-services2, azure, azure-cosmos
Databases	jdbc, mongodb, cassandra, hbase, redis, neo4j, clickhouse, influxdb, singlestore, elasticsearch
Messaging	kafka, pulsar, rabbitmq, amqp, jms, mqtt, solace
File Formats	parquet, csv, json, xml, thrift, iceberg
Other	snowflake, splunk, cdap, debezium, hadoop-format, kudu, solr, tika

Testing I/O Connectors

Unit Tests

bash

./gradlew :sdks:java:io:kafka:test
./gradlew :sdks:java:io:jdbc:test

Integration Tests

On Direct Runner

bash

./gradlew :sdks:java:io:google-cloud-platform:integrationTest

With Custom GCP Settings

bash

./gradlew :sdks:java:io:google-cloud-platform:integrationTest \
  -PgcpProject=<project> \
  -PgcpTempRoot=gs://<bucket>/path

With Explicit Pipeline Options

bash

./gradlew :sdks:java:io:jdbc:integrationTest \
  -DbeamTestPipelineOptions='["--runner=TestDirectRunner"]'

Integration Test Framework

Located at it/ directory:

it/common/ - Common test utilities
it/google-cloud-platform/ - GCP-specific test infrastructure
it/jdbc/ - JDBC test infrastructure
it/kafka/ - Kafka test infrastructure
it/testcontainers/ - Testcontainers support

Writing Integration Tests

Basic Structure

java

@RunWith(JUnit4.class)
public class MyIOIT {
  @Rule public TestPipeline readPipeline = TestPipeline.create();
  @Rule public TestPipeline writePipeline = TestPipeline.create();

  @Test
  public void testWriteAndRead() {
    // Write data
    writePipeline.apply(Create.of(testData))
                 .apply(MyIO.write().to(destination));
    writePipeline.run().waitUntilFinish();

    // Read and verify
    PCollection<String> results = readPipeline.apply(MyIO.read().from(destination));
    PAssert.that(results).containsInAnyOrder(expectedData);
    readPipeline.run().waitUntilFinish();
  }
}

Using TestPipeline

java

@Rule public TestPipeline pipeline = TestPipeline.create();

TestPipeline:

Blocks on run by default (on TestDataflowRunner)
Has 15-minute default timeout
Reads options from beamTestPipelineOptions system property

GCP I/O Connectors

BigQuery

java

// Read
pipeline.apply(BigQueryIO.readTableRows().from("project:dataset.table"));

// Write
data.apply(BigQueryIO.writeTableRows()
    .to("project:dataset.table")
    .withSchema(schema)
    .withWriteDisposition(WriteDisposition.WRITE_APPEND));

Pub/Sub

java

// Read
pipeline.apply(PubsubIO.readStrings().fromTopic("projects/project/topics/topic"));

// Write
data.apply(PubsubIO.writeStrings().to("projects/project/topics/topic"));

Cloud Storage (TextIO)

java

// Read
pipeline.apply(TextIO.read().from("gs://bucket/path/*.txt"));

// Write
data.apply(TextIO.write().to("gs://bucket/output").withSuffix(".txt"));

Kafka Connector

java

// Read
pipeline.apply(KafkaIO.<String, String>read()
    .withBootstrapServers("localhost:9092")
    .withTopic("topic")
    .withKeyDeserializer(StringDeserializer.class)
    .withValueDeserializer(StringDeserializer.class));

// Write
data.apply(KafkaIO.<String, String>write()
    .withBootstrapServers("localhost:9092")
    .withTopic("topic")
    .withKeySerializer(StringSerializer.class)
    .withValueSerializer(StringSerializer.class));

JDBC Connector

java

// Read
pipeline.apply(JdbcIO.<Row>read()
    .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration
        .create("org.postgresql.Driver", "jdbc:postgresql://host/db"))
    .withQuery("SELECT * FROM table"));

// Write
data.apply(JdbcIO.<Row>write()
    .withDataSourceConfiguration(config)
    .withStatement("INSERT INTO table VALUES (?, ?)"));

Python I/O Location

sdks/python/apache_beam/io/

Common Python I/Os

textio - Text files
fileio - General file operations
avroio - Avro files
parquetio - Parquet files
gcp/ - GCP connectors (BigQuery, Pub/Sub, Datastore, etc.)

Cross-language I/O

Beam supports using I/O connectors from one SDK in another via the expansion service.

bash

# Start Java expansion service
./gradlew :sdks:java:io:expansion-service:runExpansionService

Creating New Connectors

Key components:

Source - Reads data (bounded or unbounded)
Sink - Writes data
Read/Write transforms - User-facing API

For more detailed information on developing new I/O connectors see the Developing new I/O connectors SKILL.

Files

SKILL.md and 1 other file in skills/io-connectors of Kilo-Org/kilo-marketplace.

SKILL.md
LICENSE

Open the folder on GitHubat commit ff51758

Compare with similar skills

Io Connectors next to the 5 skills that share the most tags, products or categories with it. Stars are the repository's; “used in” counts other GitHub owners with a copy.

Io Connectors compared with similar skills
Skill	Stars	Used in	Tokens	Auto-check	Licence	Repo updated
Io Connectors this skillKilo-Org/kilo-marketplace	190	—	~1.3k	Automated safety check: Pass	Apache-2.0	11 days ago
BigQuery Slot and Cost Optimizergoogle/skills	21k	—	~2.3k	Automated safety check: Pass	Apache-2.0	today
Bigquery Bigframesgoogle/skills	21k	—	~1.3k	Automated safety check: Pass	Apache-2.0	today
Cloud Monitoring Metric Selectiongoogle/skills	21k	—	~2.4k	Automated safety check: Pass	Apache-2.0	today
323 Frameworks Spring Boot Testing Acceptance Testsjabrena/plinth	447	—	~1.2k	Automated safety check: Pass	Apache-2.0	2 days ago
Google Cloud Storage Basicsgoogle/skills	21k	—	~2.8k	Automated safety check: Pass	Apache-2.0	today

Similar skills

BigQuery Slot and Cost Optimizer
google/skills
Official
Analyzes BigQuery slot use, query costs and execution bottlenecks from INFORMATION_SCHEMA to diagnose slow queries, slot contention and unpartitioned scans.
21k GitHub stars~2.3k tokensUpdated today
DatabasesAuto-check passed
Bigquery Bigframes
google/skills
Official
Generates Python code using BigQuery DataFrames (BigFrames).
21k GitHub stars~1.3k tokensUpdated today
DatabasesAuto-check passed
Cloud Monitoring Metric Selection
google/skills
Official
Retrieve, query, and identify relevant Cloud Monitoring metric descriptors on Google Cloud for a service or resource (such as Compute Engine, Spanner, BigQuery, Cloud Run, Cloud SQL, Pub/Sub, Cloud…
21k GitHub stars~2.4k tokensUpdated today
DatabasesAuto-check passed
323 Frameworks Spring Boot Testing Acceptance Tests
jabrena/plinth
A skill your agent uses when you need to implement acceptance tests from maintainer-authored or maintainer-sanitized Gherkin scenario facts for Spring Boot applications — including selecting…
447 GitHub stars~1.2k tokensUpdated 2 days ago
Backend & APIsAuto-check passed
Google Cloud Storage Basics
google/skills
Official
Stores, retrieves, and manages data as objects in Cloud Storage on Google Cloud (also known colloquially as GCS) buckets.
21k GitHub stars~2.8k tokensUpdated today
Agent WorkflowsAuto-check passed
Streaming Data
ancoleman/ai-design-components
Build event streaming and real-time data pipelines with Kafka, Pulsar, Redpanda, Flink, and Spark.
526 GitHub stars~2.9k tokensUpdated 10 mo ago
Backend & APIsAuto-check passed

More from Kilo-Org/kilo-marketplace

All 86 skills in this repo

AzureML Project Scaffolding
Kilo-Org/kilo-marketplace
Sets up and maintains AzureML-ready Python projects as uv workspaces with devcontainers, a Makefile and job YAML, so local runs match cloud jobs and experiments stay reproducible.
190 GitHub stars~3.1k tokensUpdated 11 days ago
Auto-check: notes
Jupyter Notebook Builder
Kilo-Org/kilo-marketplace
Creates, inspects, edits and runs Jupyter notebooks, scaffolding experiment or tutorial notebooks from templates and preferring a Jupyter MCP server over raw JSON edits.
190 GitHub stars~1.3k tokensUpdated 11 days ago
Auto-check passed
Tableau Dashboard Creator
Kilo-Org/kilo-marketplace
Takes a plain-language dashboard request through brand setup, data exploration, planning, an interactive HTML mock and a Tableau implementation spec.
190 GitHub stars~3.8k tokensUpdated 11 days ago
Auto-check: notes
Elasticsearch File Ingest
Kilo-Org/kilo-marketplace
Ingest and transform data files (CSV/JSON/Parquet/Arrow IPC) into Elasticsearch with stream processing and custom transforms.
190 GitHub stars~2.8k tokensUpdated 11 days ago
Auto-check passed
Nifi Flow Layout
Kilo-Org/kilo-marketplace
A skill your agent uses when arranging Apache NiFi processors, process groups, ports, comments, numbering, crossing connections, dense fan-in/fan-out, or reusable readable canvas layouts.
190 GitHub stars~1.5k tokensUpdated 11 days ago
Auto-check passed
Splunk Ingest Processor Setup
Kilo-Org/kilo-marketplace
Render Cisco Data Fabric ingest-time routing workflows and Splunk Cloud Platform Ingest Processor setup plans with SPL2 pipelines, source types, destinations, lifecycle handoffs, queue and…
190 GitHub stars~1.2k tokensUpdated 11 days ago
Auto-check passed

Works with

Questions about Io Connectors

What does Io Connectors do?

Guides development and usage of I/O connectors in Apache Beam. Io Connectors is an agent skill from Kilo-Org/kilo-marketplace. Guides development and usage of I/O connectors in Apache Beam.

When should I use Io Connectors?

Io Connectors fits situations like: working with I/O connectors; creating new connectors; debugging data source/sink issues.

How do I install Io Connectors in Claude Code?

Run `npx skills add Kilo-Org/kilo-marketplace --skill io-connectors -a claude-code`. Or copy the skill folder (skills/io-connectors in Kilo-Org/kilo-marketplace) into .claude/skills/io-connectors in your project. Claude Code loads it when a task matches its description.

How do I install Io Connectors in Codex?

Run `npx skills add Kilo-Org/kilo-marketplace --skill io-connectors -a codex`. Or copy the skill folder (skills/io-connectors in Kilo-Org/kilo-marketplace) into .agents/skills/io-connectors in your project. Codex loads it when a task matches its description.

Can I use Io Connectors in Cursor, Gemini CLI or GitHub Copilot?

Cursor, Gemini CLI, GitHub Copilot and OpenCode also load SKILL.md folders. With the skills CLI, run `npx skills add Kilo-Org/kilo-marketplace --skill io-connectors -a cursor` (or -a gemini-cli, github-copilot or opencode for the others). To copy it by hand, put the folder in .cursor/skills/io-connectors, .gemini/skills/io-connectors, .github/skills/io-connectors and .opencode/skills/io-connectors in your project.

What does Io Connectors need to run?

SKILL.md names no scripts, command-line tools or credentials: Io Connectors is instructions for the agent only. Our summary lists: Python 3.

Does Io Connectors access the network?

SKILL.md contains no URLs. Any network use would come from the scripts or tools the agent runs. This is read from the text; nothing was executed.

Is Io Connectors safe to install?

Our automated static check of SKILL.md found no risky patterns, such as piping downloads into a shell, reading credential files or hidden Unicode. It is not a guarantee. Review the folder before installing.

What licence does Io Connectors use?

Io Connectors is published under the Apache-2.0 licence (from the LICENSE file in the skill folder). It allows redistribution, so the full SKILL.md is shown on this page.

How many tokens does Io Connectors use?

About 1.3k tokens (SKILL.md is roughly 5.3k characters). Agents keep only the skill's name and description in context until a task matches; then they load SKILL.md in full.

What are the alternatives to Io Connectors?

Skills that share tags, products or a category with Io Connectors: BigQuery Slot and Cost Optimizer (google/skills, 21k stars), Bigquery Bigframes (google/skills, 21k stars), Cloud Monitoring Metric Selection (google/skills, 21k stars) and 323 Frameworks Spring Boot Testing Acceptance Tests (jabrena/plinth, 447 stars). The comparison table on this page puts their stars, adoption, token cost, safety result and licence side by side.

Who maintains Io Connectors?

Kilo-Org (a GitHub organization) maintains it in Kilo-Org/kilo-marketplace, which has 190 GitHub stars. The repository holds 86 skills in this directory. The repository was last updated on September 28, 2026.

Source: Kilo-Org/kilo-marketplace on GitHub. Facts on this page come from the repository at the commit we read; the author's words are quoted as theirs.

Install Io Connectors

Facts

At a glance

What it does

When your agent uses it

Example prompts

Requirements

Workflow steps

What it can do on your machine

Tool permissions

Runs code

Network

Credentials

Context cost

Safety

SKILL.md

I/O Connectors in Apache Beam

Overview

Java I/O Connectors Location

Available Connectors

Testing I/O Connectors

Unit Tests

Integration Tests

On Direct Runner

With Custom GCP Settings

With Explicit Pipeline Options

Integration Test Framework

Writing Integration Tests

Basic Structure

Using TestPipeline

GCP I/O Connectors

BigQuery

Pub/Sub

Cloud Storage (TextIO)

Kafka Connector

JDBC Connector

Python I/O Location

Common Python I/Os

Cross-language I/O

Creating New Connectors

Files

Compare with similar skills

Similar skills

More from Kilo-Org/kilo-marketplace

Related

Questions about Io Connectors