public class CSVStreamConnector extends Object implements Connector, AutoCloseable
Constructor and Description |
---|
CSVStreamConnector(String keyColumn,
String arrayElementsSeparator,
com.fasterxml.jackson.dataformat.csv.CsvSchema.Builder schemaBuilder,
InputStream in,
OutputStream out,
String... columns) |
Modifier and Type | Method and Description |
---|---|
Uid |
authenticate(String username,
String password,
OperationOptions options)
Authenticate user on a connector instance.
|
void |
close() |
Uid |
create(ObjectClass objectClass,
Set<Attribute> attrs,
OperationOptions options,
AtomicReference<Boolean> propagationAttempted)
Create user / group on a connector instance.
|
void |
delete(ObjectClass objectClass,
Uid uid,
OperationOptions options,
AtomicReference<Boolean> propagationAttempted)
Delete user / group on a connector instance.
|
void |
dispose()
Dispose of any resources associated with connector instance.
|
List<String> |
getColumns(CSVPullSpec spec) |
ConnInstance |
getConnInstance()
Getter for active connector instance.
|
SyncToken |
getLatestSyncToken(ObjectClass objectClass)
Read latest sync token from a connector instance.
|
ConnectorObject |
getObject(ObjectClass objectClass,
Attribute connObjectKey,
boolean ignoreCaseMatch,
OperationOptions options)
Get remote object.
|
Set<ObjectClassInfo> |
getObjectClassInfo()
Builds metadata description of ConnId
ObjectClass . |
MappingIterator<Map<String,String>> |
reader() |
SearchResult |
search(ObjectClass objectClass,
Filter filter,
SearchResultsHandler handler,
OperationOptions options)
Search for remote objects.
|
void |
sync(ObjectClass objectClass,
SyncToken token,
SyncResultsHandler handler,
OperationOptions options)
Sync remote objects from a connector instance.
|
void |
test()
Check connection.
|
Uid |
update(ObjectClass objectClass,
Uid uid,
Set<Attribute> attrs,
OperationOptions options,
AtomicReference<Boolean> propagationAttempted)
Update user / group on a connector instance.
|
void |
validate()
Validate connector instance.
|
SequenceWriter |
writer() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
filteredReconciliation, fullReconciliation, search
public CSVStreamConnector(String keyColumn, String arrayElementsSeparator, com.fasterxml.jackson.dataformat.csv.CsvSchema.Builder schemaBuilder, InputStream in, OutputStream out, String... columns)
public void close() throws IOException
close
in interface AutoCloseable
IOException
public MappingIterator<Map<String,String>> reader() throws IOException
IOException
public List<String> getColumns(CSVPullSpec spec) throws IOException
IOException
public SequenceWriter writer() throws IOException
IOException
public Uid authenticate(String username, String password, OperationOptions options)
Connector
authenticate
in interface Connector
username
- the name based credential for authenticationpassword
- the password based credential for authenticationoptions
- ConnId's OperationOptionspublic ConnInstance getConnInstance()
Connector
getConnInstance
in interface Connector
public Uid create(ObjectClass objectClass, Set<Attribute> attrs, OperationOptions options, AtomicReference<Boolean> propagationAttempted)
Connector
public Uid update(ObjectClass objectClass, Uid uid, Set<Attribute> attrs, OperationOptions options, AtomicReference<Boolean> propagationAttempted)
Connector
update
in interface Connector
objectClass
- ConnId's object classuid
- user to be updatedattrs
- attributes for updateoptions
- ConnId's OperationOptionspropagationAttempted
- if creation is actually performed (based on connector instance's capabilities)public void delete(ObjectClass objectClass, Uid uid, OperationOptions options, AtomicReference<Boolean> propagationAttempted)
Connector
public void sync(ObjectClass objectClass, SyncToken token, SyncResultsHandler handler, OperationOptions options)
Connector
public SyncToken getLatestSyncToken(ObjectClass objectClass)
Connector
getLatestSyncToken
in interface Connector
objectClass
- ConnId's object class.public ConnectorObject getObject(ObjectClass objectClass, Attribute connObjectKey, boolean ignoreCaseMatch, OperationOptions options)
Connector
public SearchResult search(ObjectClass objectClass, Filter filter, SearchResultsHandler handler, OperationOptions options)
Connector
public Set<ObjectClassInfo> getObjectClassInfo()
Connector
ObjectClass
.getObjectClassInfo
in interface Connector
public void validate()
Connector
public void test()
Connector
Copyright © 2010–2023 The Apache Software Foundation. All rights reserved.