Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cata-network/cata_database
/ functions
Functions
323 in github.com/cata-network/cata_database
⨍
Functions
323
◇
Types & classes
42
↓ 1 callers
Method
getMyself
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSContext.java:60
↓ 1 callers
Method
getName
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriter.java:51
↓ 1 callers
Method
getNewLineDelimiter
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:93
↓ 1 callers
Method
getNumWorkerThreads
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:120
↓ 1 callers
Method
getPartialRootHash
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:409
↓ 1 callers
Method
getPort
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:104
↓ 1 callers
Method
getPos
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:111
↓ 1 callers
Method
getPos
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:160
↓ 1 callers
Method
getQuote
Returns the character used for escaping values where the field delimiter is part of the value. Defaults to '"' @return the quote character
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:101
↓ 1 callers
Method
getQuote
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextFormatConfig.java:28
↓ 1 callers
Method
getQuoteEscape
Returns the character used for escaping quotes inside an already quoted value. Defaults to '"' @return the quote escape character
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:131
↓ 1 callers
Method
getRecordCount
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:52
↓ 1 callers
Method
getRecordCount
Return the total number of records (across batches) processed
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextOutput.java:71
↓ 1 callers
Method
getSchema
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:62
↓ 1 callers
Method
getStoragePlugin
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSContext.java:64
↓ 1 callers
Method
getTargetHash
(IPFSHelper helper)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:149
↓ 1 callers
Method
handleException
Helper method to handle exceptions caught while processing text files and generate better error messages associated with the exception. @param ex Exc
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:423
↓ 1 callers
Method
hasDrillbitAddress
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSPeer.java:44
↓ 1 callers
Method
init
(Map<String, String> writerOptions)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:41
↓ 1 callers
Method
init
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:89
↓ 1 callers
Method
isDrillReady
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSPeer.java:36
↓ 1 callers
Method
isHeaderExtractionEnabled
Indicates whether or not the first valid record parsed from the input should be considered as the row containing the names of each column @return true
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:221
↓ 1 callers
Method
isIgnoreLeadingWhitespaces
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:269
↓ 1 callers
Method
isIgnoreTrailingWhitespaces
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:277
↓ 1 callers
Method
isParseUnescapedQuotes
Indicates whether the CSV parser should accept unescaped quotes inside quoted values and parse them normally. Defaults to {@code true}. @return a flag
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:204
↓ 1 callers
Method
isSkipFirstLine
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:64
↓ 1 callers
Method
isSkipFirstLine
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextFormatConfig.java:64
↓ 1 callers
Method
isUseRepeatedVarChar
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:72
↓ 1 callers
Method
iterator
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:99
↓ 1 callers
Method
mark
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:164
↓ 1 callers
Method
of
(String which)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:52
↓ 1 callers
Method
parseField
Captures the entirety of parsing a single field and based on the input delegates to the appropriate function @return @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:305
↓ 1 callers
Method
parsePath
(String path)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:113
↓ 1 callers
Method
parseQuotedValue
Recursive function invoked when a quote is encountered. Function also handles the case when there are non-white space characters in the field after th
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:224
↓ 1 callers
Method
parseRecord
Function encapsulates parsing an entire record, delegates parsing of the fields to parseField() function. We mark the start of the record and if there
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:123
↓ 1 callers
Method
parseValue
Function simply delegates the parsing of a single field to the actual implementation based on parsing config @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:209
↓ 1 callers
Method
parseValueAll
Function parses an individual field and appends all characters till the delimeter (or newline) to the output, including white spaces @throws IOExcepti
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:191
↓ 1 callers
Method
parseValueIgnore
Function parses an individual field and ignores any white spaces encountered by not appending it to the output vector @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:171
↓ 1 callers
Method
read
read some more bytes from the stream. Uses the zero copy interface if available. Otherwise, does byte copy. @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:173
↓ 1 callers
Method
resetForNextBatch
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:107
↓ 1 callers
Method
rowHasData
Helper method to check if the current record has any non-empty fields
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextOutput.java:86
↓ 1 callers
Method
seek
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/SeekableByteArrayInputStream.java:44
↓ 1 callers
Method
setExecutorService
(ExecutorService executorService)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:66
↓ 1 callers
Method
setHeaderExtractionEnabled
Defines whether or not the first valid record parsed from the input should be considered as the row containing the names of each column @param headerE
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingSettings.java:229
↓ 1 callers
Method
setHolder
(SchemaPlus pulsOfThis)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:50
↓ 1 callers
Method
setMaxPeersPerLeaf
(int maxPeersPerLeaf)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:78
↓ 1 callers
Method
setMyself
(IPFSPeer myself)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:74
↓ 1 callers
Method
setOnEndpoint
(DrillbitEndpoint endpointAddress)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:411
↓ 1 callers
Method
setTimeouts
(Map<IPFSTimeOut, Integer> timeouts)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:70
↓ 1 callers
Method
setupNewSchema
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:173
↓ 1 callers
Method
startBatch
Informs output to setup for new record batch.
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextOutput.java:76
↓ 1 callers
Method
stop
{@inheritDoc}
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:40
↓ 1 callers
Method
updateLengthBasedOnConstraint
Checks to see if we can go over the end of our bytes constraint on the data. If so, adjusts so that we can only read to the last character of the fir
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:233
↓ 1 callers
Method
updateRunningCount
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordReader.java:198
↓ 1 callers
Method
updateSchema
(VectorAccessible batch)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:50
↓ 1 callers
Method
validateSymbol
(String header)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/HeaderBuilder.java:103
Method
DefaultWeakReference
(T referent, T default_)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:45
Method
FieldVarCharOutput
We initialize and add the varchar vector for each incoming field in this constructor. @param outputMutator Used to create/modify schema @param fieldN
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/FieldVarCharOutput.java:79
Method
Format
(String prefix)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:68
Method
IPFSAggWriterPrule
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSAggWriterPrule.java:15
Method
IPFSContext
(IPFSStoragePluginConfig config, IPFSStoragePlugin plugin, IPFS client)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSContext.java:35
Method
IPFSGroupScan
(@JsonProperty("IPFSScanSpec") IPFSScanSpec ipfsScanSpec, @JsonProperty("IPFSStoragePlu
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:65
Method
IPFSHelper
(IPFS ipfs)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSHelper.java:61
Method
IPFSJSONRecordReader
(FragmentContext fragmentContext, IPFSContext ipfsContext, String scanSpec, List<SchemaPath> columns)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordReader.java:50
Method
IPFSJSONRecordWriter
(OperatorContext context, IPFSContext ipfsContext, String name)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:30
Method
IPFSPeer
(IPFSHelper helper, Multihash id)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSPeer.java:21
Method
IPFSScanSpec
(@JacksonInject StoragePluginRegistry registry, @JsonProperty("IPFSStoragePluginConfig"
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:96
Method
IPFSSchemaFactory
(IPFSContext context, String name)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:29
Method
IPFSStoragePlugin
(IPFSStoragePluginConfig config, DrillbitContext context, String name)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePlugin.java:30
Method
IPFSStoragePluginConfig
( @JsonProperty("host") String host, @JsonProperty("port") int port, @JsonProperty("ma
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:78
Method
IPFSSubScan
(@JacksonInject StoragePluginRegistry registry, @JsonProperty("IPFSStoragePluginConfig")
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:44
Method
IPFSSubScanSpec
(@JsonProperty("targetHash") String targetHash)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:122
Method
IPFSTables
(String name)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSchemaFactory.java:45
Method
IPFSTextRecordReader
(IPFSContext ipfsContext, Multihash targetHash, TextParsingSettings settings, List<SchemaPath> columns)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/IPFSTextRecordReader.java:47
Method
IPFSTimeOut
(String which)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSStoragePluginConfig.java:48
Method
IPFSTreeFlattener
(Multihash hash, boolean isProvider)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:105
Method
IPFSWork
(String root)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:401
Method
IPFSWriter
( @JsonProperty("child") PhysicalOperator child, @JsonProperty("name") String name, @JsonPro
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriter.java:23
Method
IPFSWriterRecordBatch
(Writer writer, RecordBatch incoming, FragmentContext context, RecordWriter recordWriter, boolean isForeman)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:39
Method
Prefix
(String prefix)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSScanSpec.java:38
Method
RepeatedVarCharOutput
We initialize and add the repeated varchar vector to the record batch in this constructor. Perform some sanity checks if the selected columns are vali
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:118
Method
SeekableByteArrayInputStream
(byte[] recommendationBytes)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/SeekableByteArrayInputStream.java:36
Method
StreamFinishedPseudoException
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/StreamFinishedPseudoException.java:24
Method
TextInput
Creates a new instance with the mandatory characters for handling newlines transparently. lineSeparator the sequence of characters that represent a ne
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:93
Method
TextParsingContext
(TextInput input, TextOutput output)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:32
Method
TextReader
The CsvParser supports all settings provided by {@link CsvParserSettings}, and requires this configuration to be properly initialized. @param settings
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:73
Method
accept
( PhysicalVisitor<T, X, E> physicalVisitor, X value)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSSubScan.java:93
Method
append
(byte data)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/RepeatedVarCharOutput.java:270
Method
append
(byte data)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/FieldVarCharOutput.java:169
Method
apply
(@Nullable SchemaPath path)
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/IPFSTextRecordReader.java:60
Method
applyAssignments
(List<DrillbitEndpoint> incomingEndpoints)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:306
Method
canPushdownProjects
(List<SchemaPath> columns)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:368
Method
checkForNewPartition
(int index)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSJSONRecordWriter.java:56
Method
clone
(List<SchemaPath> columns)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:360
Method
close
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSWriterRecordBatch.java:227
Method
close
Invoked once there are no more records and we are done with the current record reader to clean up state. @throws IOException
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextReader.java:497
Method
close
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextInput.java:360
Method
columnsReordered
()
src/main/java/org/apache/drill/exec/store/ipfs/formats/text/compliant/TextParsingContext.java:117
Method
compareTo
(CompleteWork o)
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:425
Method
compute
()
src/main/java/org/apache/drill/exec/store/ipfs/IPFSGroupScan.java:110
← previous
next →
101–200 of 323, ranked by callers