Могу ли я сделать индивидуальные входные данные для моего картографа в работе mapreduce?
Если вы хотите обработать текстовый файл или файл журнала с помощью mapreduce по умолчанию, входное значение преобразователя будет соответствовать строке новой строки, но я хочу обработать файл журнала
A (18:18:43,703 [ERROR] AccStmtGeneratorImpl - Statement not generated for::304005)
B (11:40:04,202 [ERROR] JobStoreTX - Failed to close Connection
java.sql.SQLException: Already closed.
at org.apache.commons.dbcp.PoolableConnection.close(PoolableConnection.java:114)
at `enter code here`org.apache.commons.dbcp.PoolingDataSource$PoolGuardConnectionWrapper.close(PoolingDataSource.java:191)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.closeConnection(JobStoreSupport.java:3579)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.cleanupConnection(JobStoreSupport.java:3555)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.executeInNonManagedTXLock(JobStoreSupport.java:3783)
at org.quartz.impl.jdbcjobstore.JobStoreSupport.acquireNextTrigger(JobStoreSupport.java:2728)
at org.quartz.core.QuartzSchedulerThread.run(QuartzSchedulerThread.java:264)
)
здесь мой маппер должен принимать значение от 11:40:04,202 до новой отметки времени, что означает, что A будет значением, а весь B будет другим значением, так как я могу это сделать? заранее спасибо пожалуйста помогите...