Homepage/Cloudera Streaming Analytics1.6.2

(Private Cloud)

Search Documentation

▶︎Cloudera
1. Reference Architectures
▶︎Cloudera Public Cloud
▼Cloudera Private Cloud
▶︎Cloudera Manager
1. Cloudera Manager
▶︎Applications
▶︎Legacy
▶︎

Data Services
Getting Started
Cloudera Manager
Management Console
Data Engineering
Data Warehouse
CDW Runtime
Machine Learning
Base
Getting Started
Runtime & Cloudera Manager
Upgrade
Flow Management
Streaming Analytics

«

Filter topics

Cloudera Streaming Analytics
▶︎Release Notes
▶︎Download
1. Download location of CSA
▶︎Apache Flink Overview
▶︎SQL Stream Builder Overview
▶︎Quick Start
1. ▶︎DataStream Applications
  1. Quick Start for Flink
  2. Flink Project Template
2. ▶︎SQL Stream Applications
  1. Quick Start for SSB
▶︎Deployment
▶︎Installation & Upgrade
▶︎Security
1. ▶︎Securing Apache Flink
2. ▶︎Securing SQL Stream Builder
▼Using SQL Stream Builder
▶︎Using Apache Flink
▶︎Storm Flink Migration
1. ▶︎Comparing Storm and Flink
2. Migrating from Storm to Flink
SQL Stream Builder REST API Reference

Accessing the Flink Dashboard through Knox
Accessing the Streaming SQL Console through Knox
Adding Custom Catalogs
Adding data formats
Adding Flink as a Service
Adding Hive as Catalog
Adding Java to the Functions language option
Adding Kafka as Data Provider
Adding Kudu as Catalog
Adding new connectors
Adding Schema Registry as Catalog
Adding SSB as a service
Adjusting logging configuration in Advanced Settings
ALTER Statements
Apache Flink Overview
Application Development
Assigning Kafka keys in streaming queries
Atlas entities in Flink metadata collection
Authentication and encryption for Flink
Authentication in SSB
Avro format
Blackhole connector
CDC connectors
Cloudera Flink Tutorials
Cloudera Streaming Analytics
ClouderaRegistryKafkaDeserializationSchema
ClouderaRegistryKafkaSerializationSchema
Cluster service layout with Flink
Cluster service layout with SSB
Comparing Storm and Flink
Component support
Compose Tab
Concept of tables in SSB
Conceptual differences
Configuring custom Kerberos principal for Apache Flink
Configuring custom Kerberos principal for SQL Stream Builder
Configuring databases for SSB
Configuring Flink application resources
Configuring Flink applications
Configuring Kafka tables
Configuring Ranger policies for Flink
Configuring Ranger policies for SSB
Configuring RocksDB state backend
Configuring SQL job settings
Connector support in SSB
Connectors
Console Page
Converting DataStreams to Tables
Converting Tables to DataStreams
Core Features of Flink
CREATE Statements
Creating and configuring the HBaseSinkFunction
Creating Atlas entity type definitions for Flink
Creating Flink tables using Templates
Creating Input Transforms
Creating Kafka tables
Creating Kafka tables using Console wizard
Creating Kafka tables using Templates
Creating Materialized Views
Creating new Flink application versions
Creating Tables
Creating User Defined Functions
Creating Webhook tables
CSV format
Data Providers
Data Providers Page
Data Types
Data types for Kafka connector
Datagen connector
DataStream API interoperability
DataStream Applications
DataStream Connectors
Default ports for Flink and SSB
Deployment
Deployment scenarios
Deserialization tab
Developing JavaScript functions
Differences in architecture
Differences in data distribution
Download
Download location of CSA
DROP Statements
Dynamic SQL Hints
Enabling checkpoints for Flink applications
Enabling Flink DEBUG logging
Enabling Kerberos authentication
Enabling Knox authentication
Enabling Knox authentication for Flink Dashboard
Enabling Knox Auto Discovery for Flink
Enabling Knox for SSB in CDP Private Cloud Base 7.1.6
Enabling Knox for SSB in CDP Private Cloud Base 7.1.7
Enabling Knox manually for Flink Dashboard
Enabling savepoints for Flink applications
Enabling security for Apache Flink
Enabling SPNEGO authentication for Flink Dashboard
Enabling TLS for database connection
Encryption in SSB
Enriching streaming data with join
Event Time tab
Example: joining Kafka and Kudu tables
Executing SQL jobs in production mode
Faker connector
Filesystem connector
Fixed issues
Flink API Support
Flink application example
Flink application structure
Flink Dashboard
Flink DDL
Flink DML
Flink metadata collection using Atlas
Flink Project Template
Flink Queries
Flink SQL
Flink SQL and Table API
Flink SQL Overview
Flink Terminology
Functions Tab
Getting Started
Getting Started
Governance
Governance
HBase sink with Flink
History Tab
Hive catalog
Input Transforms
INSERT Statements
Installation
Installing CSD and parcel
Introduction to Materialized Views
Introduction to SQL Stream Builder
JDBC connector
Job Lifecycle
Job Lifecycle
Joining streaming and bounded tables
JSON format
Kafka connector
Kafka connectors
Kafka Metrics Reporter
Kafka with Flink
Key features of SSB
Known issues and limitations
Kudu catalog
Kudu with Flink
Managing connectors and data formats
Managing registered Data Providers
Managing session for SQL jobs
Managing teams in Streaming SQL Console
Managing time in SSB
Materialized Views
Materialized Views Page
Migrating Flink service to a different host
Migrating from Storm to Flink
Migrating SQL jobs
Migration
Monitoring
Monitoring
Monitoring SQL Stream jobs
Other supported statements
Performance & Scalability
Properties tab
Quick Start for Flink
Quick Start for SSB
Reference
Registering Data Providers in SSB
Release Notes
REST API
Resuming Flink applications
Resuming SQL jobs
Running a Flink job
Running a simple Flink application
Running a simple SQL job
Running SQL Stream jobs
Sampling data for a running job
Schema Registry Avro format
Schema Registry catalog
Schema Registry with Flink
Schema tab
Securing Apache Flink
Securing Apache Flink jobs
Securing SQL Stream Builder
Security
Setting parallelism and max parallelism
Setting the Java executable for the Flink client
Setting up MySQL/MariaDB database for SSB
Setting up Oracle database for SSB
Setting up PostgreSQL database for SSB
Setting up your HDFS Home directory
Source, operator and sink in DataStream API
SQL and Table API
SQL and Table API supported features
SQL catalogs for Flink
SQL connectors for Flink
SQL Examples
SQL Jobs Tab
SQL Queries in Flink
SQL Statements in Flink
SQL Stream Applications
SQL Stream Builder architecture
SQL Stream Builder Overview
SSB fails with missing JAR file error
SSB metadata collection using Atlas
Stopping Flink applications
Stopping SQL Stream jobs
Stopping, restarting and editing SQL jobs
Storm Flink Migration
Streaming Analytics in Cloudera
Streaming SQL Console
Streams Messaging Manager integration
Support Matrix
Supported basic data types
Supported data types
System Requirements
Tables Tab
Testing and validating Flink applications
Transformations tab
Unsupported features
Upgrade
Upgrading CSA artifacts for Flink service
Upgrading CSA artifacts for SQL Stream Builder service
Upgrading Flink service
Upgrading SQL Stream Builder service
Uploading and unlocking your keytab in SSB
User Defined Functions
Using Dynamic Materialized View Endpoints
Using EncryptTool for Flink properties
Using Flink CLI
Using SQL Stream Builder REST API
Using SQL Stream Builder with Cloudera Data Visualization
Using System Functions
Using the Streaming SQL Console
Verifying metadata collection
What is Apache Flink?
What's new in Cloudera Streaming Analytics

«

Filter topics

Functions Tab

▼Using the Streaming SQL Console

»

Streaming SQL Console

Functions Tab

The Functions tab shows the list of created User Defined Functions (UDF) that you can use in your SQL queries.

Parent topic: Console Page

© 2019–2021 by Cloudera, Inc. All rights reserved.

This site uses cookies and related technologies, as described in our privacy policy, for purposes that may include site operation, analytics, enhanced user experience, or advertising. You may choose to consent to our use of these technologies, or

1.14.0
1.13.3
1.13.2
1.13.1
1.13.0
1.12.0
1.11.2
1.11.1
1.11.0
1.10.0
1.9.0
1.8.0
1.7.0
1.6
1.5
1.4
1. 1.4.1
2. 1.4.0
1.3.0
1.2.0
1.1.0