public interface CCAPI
限定符和类型 | 方法和说明 |
---|---|
JSONArray |
getACSet()
API发布服务获得访控策略中的'访问范围'权限集
|
<T> T |
getAPI(java.lang.String cconnectorType,
java.lang.Object... args) |
DataServiceAPI |
getDataServiceAPI(java.lang.String dsId)
获得一个DataServiceAPI的操作对象(内置相应ConnectorAPI)
|
Adapter.DB |
getDBAPI(java.lang.String profileId)
已过时。
已停止维护,推荐使用getRDSAPI()
|
EsAPI |
getESAPI(java.lang.String profileId)
根据配置,获得一个Elasticsearch操作对象
|
FtpAPI |
getFtpAPI(java.lang.String profileId)
获得一个通用FTP操作对象(连接文件传输服务)
|
HadoopAPI |
getHadoopAPI(java.lang.String profileId)
根据配置,获得一个Hadoop操作对象(连接分布式大数据计算服务)
|
HBaseAPI |
getHBaseAPI(java.lang.String profileId)
根据配置,获得一个HBase操作对象(连接分布式K/V大数据库服务)
|
HttpAPI |
getHttpAPI()
已过时。
|
HttpAPI |
getHttpAPI(java.lang.String connectorId)
获得一个通用HTTP操作对象(连接Web服务)
|
JmsAPI |
getJMSAPI(java.lang.String profileId)
根据配置,获得一个JMS操作对象,如:ActiveMQ
|
<K,V> KafkaAPI<K,V> |
getKafkaAPI(java.lang.String profileId)
根据配置,获得一个Kafka API对象(连接分布式消息服务)
|
<K,V> KafkaAPI<K,V> |
getKafkaAPI(java.lang.String profileId,
<any> keySerializer,
<any> valueSerializer)
获得kafka API对象,用于发送
|
<K,V> KafkaAPI<K,V> |
getKafkaAPI(java.lang.String profileId,
<any> keyDeserializer,
<any> valueDeserializer)
获得kafka API对象,用于接收,Deserializer
|
LDAPAPI |
getLDAPAPI(java.lang.String profileId)
根据配置,获得一个LDAP操作对象(连接目录服务)
|
MongoDBAPI |
getMongoDBAPI(java.lang.String profileId)
根据配置,获得一个MongoDB操作对象(连接文档型数据库服务)
|
NativeCallAPI |
getNativeCallAPI()
根据配置,获得一个NativeCall操作对象(执行外部shell命令)
|
RabbitmqAPI |
getRabbitmqAPI(java.lang.String profileId)
根据配置,获得一个RabbitMQ操作对象
|
RDSAPI |
getRDSAPI(java.lang.String profileId)
获得CC DB数据库API
|
<K,V> RedisAPI<K,V> |
getRedisAPI(java.lang.String profileId)
根据配置,获得一个Redis操作对象(连接分布式K/V缓存服务)
redis connector2.0版本之后,用lettuce作为默认实现,原jedis不建议再使用
|
com.actionsoft.sdk.local.api.cc.RocketmqAPI |
getRocketmqAPI(java.lang.String profileId)
根据配置,获得一个RocketMQ操作对象
|
SAPAPI |
getSAPAPI(java.lang.String profileId) |
SOAPAPI |
getSOAPAPI(java.lang.String profileId)
根据配置,获得一个WebService客户端(连接Web Service服务)
|
SparkAPI |
getSparkAPI(java.lang.String profileId)
根据配置,获得一个Spark操作对象(连接分布式内存计算服务)
|
StormAPI |
getStormAPI(java.lang.String profileId)
根据配置,获得一个Storm操作对象(连接分布式实时流计算服务)
|
Adapter.WS |
getWebServiceAPI(java.lang.String profileId)
已过时。
已停止维护,推荐使用getSOAPAPI()
|
ZooKeeperAPI |
getZooKeeperAPI(java.lang.String profileId)
根据配置,获得一个ZooKeeper操作对象(连接分布式调度服务)
|
JSONArray getACSet()
RDSAPI getRDSAPI(java.lang.String profileId)
profileId
- CC RDS配置IDSOAPAPI getSOAPAPI(java.lang.String profileId)
profileId
- CC SOAP WebService配置IDAdapter.WS getWebServiceAPI(java.lang.String profileId)
profileId
- 配置IDAdapter.DB getDBAPI(java.lang.String profileId)
profileId
- 配置ID@Deprecated HttpAPI getHttpAPI()
HttpAPI getHttpAPI(java.lang.String connectorId)
connectorId
- 连接器IDDataServiceAPI getDataServiceAPI(java.lang.String dsId)
dsId
- DataService IDFtpAPI getFtpAPI(java.lang.String profileId)
LDAPAPI getLDAPAPI(java.lang.String profileId)
profileId
- 配置IDNativeCallAPI getNativeCallAPI()
MongoDBAPI getMongoDBAPI(java.lang.String profileId)
profileId
- 配置ID<K,V> RedisAPI<K,V> getRedisAPI(java.lang.String profileId)
profileId
- 配置IDZooKeeperAPI getZooKeeperAPI(java.lang.String profileId)
profileId
- 配置ID<K,V> KafkaAPI<K,V> getKafkaAPI(java.lang.String profileId)
profileId
- 配置ID<K,V> KafkaAPI<K,V> getKafkaAPI(java.lang.String profileId, <any> keySerializer, <any> valueSerializer)
profileId
- CC Kafka配置IDkeySerializer
- 键序列化对象valueSerializer
- 值序列化对象<K,V> KafkaAPI<K,V> getKafkaAPI(java.lang.String profileId, <any> keyDeserializer, <any> valueDeserializer)
profileId
- CC Kafka配置IDkeyDeserializer
- 键反序列化对象valueDeserializer
- 值反序列化对象EsAPI getESAPI(java.lang.String profileId)
JmsAPI getJMSAPI(java.lang.String profileId)
RabbitmqAPI getRabbitmqAPI(java.lang.String profileId)
com.actionsoft.sdk.local.api.cc.RocketmqAPI getRocketmqAPI(java.lang.String profileId)
SparkAPI getSparkAPI(java.lang.String profileId)
profileId
- 配置IDHadoopAPI getHadoopAPI(java.lang.String profileId)
profileId
- 配置IDHBaseAPI getHBaseAPI(java.lang.String profileId)
profileId
- 配置IDStormAPI getStormAPI(java.lang.String profileId)
profileId
- 配置IDSAPAPI getSAPAPI(java.lang.String profileId)
<T> T getAPI(java.lang.String cconnectorType, java.lang.Object... args)
Copyright © Actionsoft Co., Ltd. All Rights Reserved.